Feb 28, 2025 · Feb 27, 2025
diff --git a/tests/test_simple_remote.py b/tests/test_simple_remote.py
                    con.begin('Garbage').commit()

    def test_ports_management(self):
        # check that no ports have been bound yet
        assert (len(bound_ports) == 0)
        assert bound_ports is not None
        assert type(bound_ports) == set  # noqa: E721

        if len(bound_ports) != 0:
            logging.warning("bound_ports is not empty: {0}".format(bound_ports))

        stage0__bound_ports = bound_ports.copy()

        with __class__.helper__get_node() as node:
            # check that we've just bound a port
            assert (len(bound_ports) == 1)
            assert bound_ports is not None
            assert type(bound_ports) == set  # noqa: E721

            assert node.port is not None
            assert type(node.port) == int  # noqa: E721

            logging.info("node port is {0}".format(node.port))

            assert node.port in bound_ports
            assert node.port not in stage0__bound_ports

            assert stage0__bound_ports <= bound_ports
            assert len(stage0__bound_ports) + 1 == len(bound_ports)

            stage1__bound_ports = stage0__bound_ports.copy()
            stage1__bound_ports.add(node.port)

            # check that bound_ports contains our port
            port_1 = list(bound_ports)[0]
            port_2 = node.port
            assert (port_1 == port_2)
            assert stage1__bound_ports == bound_ports

        # check that port has been freed successfully
        assert (len(bound_ports) == 0)
        assert bound_ports is not None
        assert type(bound_ports) == set  # noqa: E721
        assert bound_ports == stage0__bound_ports

    def test_exceptions(self):
        str(StartNodeException('msg', [('file', 'lines')]))
Original file line number	Diff line number	Diff line change
Expand Up		@@ -976,20 +976,38 @@ def test_isolation_levels(self):
		con.begin('Garbage').commit()

		def test_ports_management(self):
		# check that no ports have been bound yet
		assert (len(bound_ports) == 0)
		assert bound_ports is not None
		assert type(bound_ports) == set # noqa: E721

		if len(bound_ports) != 0:
		logging.warning("bound_ports is not empty: {0}".format(bound_ports))

		stage0__bound_ports = bound_ports.copy()

		with __class__.helper__get_node() as node:
		# check that we've just bound a port
		assert (len(bound_ports) == 1)
		assert bound_ports is not None
		assert type(bound_ports) == set # noqa: E721

		assert node.port is not None
		assert type(node.port) == int # noqa: E721

		logging.info("node port is {0}".format(node.port))

		assert node.port in bound_ports
		assert node.port not in stage0__bound_ports

		assert stage0__bound_ports <= bound_ports
		assert len(stage0__bound_ports) + 1 == len(bound_ports)

		stage1__bound_ports = stage0__bound_ports.copy()
		stage1__bound_ports.add(node.port)

		# check that bound_ports contains our port
		port_1 = list(bound_ports)[0]
		port_2 = node.port
		assert (port_1 == port_2)
		assert stage1__bound_ports == bound_ports

		# check that port has been freed successfully
		assert (len(bound_ports) == 0)
		assert bound_ports is not None
		assert type(bound_ports) == set # noqa: E721
		assert bound_ports == stage0__bound_ports

		def test_exceptions(self):
		str(StartNodeException('msg', [('file', 'lines')]))
Expand Down