From 3aa889fa5785f6a568310938222ca2d0c62a98f7 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Thu, 21 Apr 2011 14:03:39 +0200 Subject: [PATCH] Tests passing --- kombu/tests/test_transport_pyredis.py | 3 ++- kombu/tests/test_transport_virtual.py | 3 --- 2 files changed, 2 insertions(+), 4 deletions(-) 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)