Ask Solem před 11 roky
rodič
revize
667f64bf1b
1 změnil soubory, kde provedl 3 přidání a 0 odebrání
  1. 3 0
      celery/tests/worker/test_loops.py

+ 3 - 0
celery/tests/worker/test_loops.py

@@ -36,6 +36,9 @@ class X(object):
                          heartbeat,
                          Mock(name='clock')]
         self.connection.supports_heartbeats = True
+        self.connection.get_heartbeat_interval.side_effect = (
+            lambda: self.heartbeat
+        )
         self.consumer.callbacks = []
         self.obj.strategies = {}
         self.connection.connection_errors = (socket.error, )