Explorar o código

unittests: Stop Timer threads after staring them.

Ask Solem %!s(int64=14) %!d(string=hai) anos
pai
achega
154e0df85f
Modificáronse 1 ficheiros con 2 adicións e 1 borrados
  1. 2 1
      celery/tests/test_worker.py

+ 2 - 1
celery/tests/test_worker.py

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