Преглед на файлове

unittests: Stop Timer threads after staring them.

Ask Solem преди 14 години
родител
ревизия
aa795790c1
променени са 1 файла, в които са добавени 2 реда и са изтрити 1 реда
  1. 2 1
      celery/tests/test_worker.py

+ 2 - 1
celery/tests/test_worker.py

@@ -371,6 +371,7 @@ class test_CarrotListener(unittest.TestCase):
         l.qos = QoS(l.task_consumer, l.initial_prefetch_count, l.logger)
         l.qos = QoS(l.task_consumer, l.initial_prefetch_count, l.logger)
         l.event_dispatcher = MockEventDispatcher()
         l.event_dispatcher = MockEventDispatcher()
         l.receive_message(m.decode(), m)
         l.receive_message(m.decode(), m)
+        l.eta_schedule.stop()
 
 
         items = [entry[2] for entry in self.eta_schedule.queue]
         items = [entry[2] for entry in self.eta_schedule.queue]
         found = 0
         found = 0
@@ -431,7 +432,7 @@ class test_CarrotListener(unittest.TestCase):
         self.assertTrue(dispatcher.flushed)
         self.assertTrue(dispatcher.flushed)
         l.event_dispatcher = MockEventDispatcher()
         l.event_dispatcher = MockEventDispatcher()
         l.receive_message(m.decode(), m)
         l.receive_message(m.decode(), m)
-
+        l.eta_schedule.stop()
         in_hold = self.eta_schedule.queue[0]
         in_hold = self.eta_schedule.queue[0]
         self.assertEqual(len(in_hold), 3)
         self.assertEqual(len(in_hold), 3)
         eta, priority, entry = in_hold
         eta, priority, entry = in_hold