Sfoglia il codice sorgente

Merge branch 'master' of github.com:celery/celery

Ask Solem 8 anni fa
parent
commit
d06b18d6e2
1 ha cambiato i file con 2 aggiunte e 2 eliminazioni
  1. 2 2
      celery/worker/components.py

+ 2 - 2
celery/worker/components.py

@@ -44,8 +44,8 @@ class Timer(bootsteps.Step):
                 w.timer_cls = w.pool_cls.Timer
                 w.timer_cls = w.pool_cls.Timer
             w.timer = self.instantiate(w.timer_cls,
             w.timer = self.instantiate(w.timer_cls,
                                        max_interval=w.timer_precision,
                                        max_interval=w.timer_precision,
-                                       on_timer_error=self.on_timer_error,
-                                       on_timer_tick=self.on_timer_tick)
+                                       on_error=self.on_timer_error,
+                                       on_tick=self.on_timer_tick)
 
 
     def on_timer_error(self, exc):
     def on_timer_error(self, exc):
         logger.error('Timer error: %r', exc, exc_info=True)
         logger.error('Timer error: %r', exc, exc_info=True)