Browse Source

Add failing test for reset_connection on a Consumer with no pool set.

Daniel Watkins 14 năm trước cách đây
mục cha
commit
7b52b4eaa5
1 tập tin đã thay đổi với 6 bổ sung0 xóa
  1. 6 0
      celery/tests/test_worker/test_worker.py

+ 6 - 0
celery/tests/test_worker/test_worker.py

@@ -513,6 +513,12 @@ class test_Consumer(unittest.TestCase):
         self.assertTrue(init_callback.call_count)
         self.assertTrue(l.consume_messages.call_count)
 
+    def test_reset_connection_with_no_node(self):
+
+        l = MainConsumer(self.ready_queue, self.eta_schedule, self.logger)
+        self.assertEqual(None, l.pool)
+        l.reset_connection()
+
 
 class test_WorkController(AppCase):