diff --git a/kombu/tests/test_transport_pyredis.py b/kombu/tests/test_transport_pyredis.py index ff841559..85802b8b 100644 --- a/kombu/tests/test_transport_pyredis.py +++ b/kombu/tests/test_transport_pyredis.py @@ -282,9 +282,10 @@ class test_Redis(unittest.TestCase): def test_close_poller_not_active(self): c = BrokerConnection(transport=Transport).channel() + cycle = c.connection.cycle c.client.connection c.close() - self.assertNotIn(c, c.connection.cycle._channels) + self.assertNotIn(c, cycle._channels) def test_close_ResponseError(self): c = BrokerConnection(transport=Transport).channel() diff --git a/kombu/tests/test_transport_virtual.py b/kombu/tests/test_transport_virtual.py index c06a4782..d0339cbf 100644 --- a/kombu/tests/test_transport_virtual.py +++ b/kombu/tests/test_transport_virtual.py @@ -342,9 +342,6 @@ class test_Transport(unittest.TestCase): def setUp(self): self.transport = client().transport - def test_close_nonexisting_channel(self): - self.transport.close_channel("foo") - def test_close_connection(self): c1 = self.transport.create_channel(self.transport) c2 = self.transport.create_channel(self.transport)