Parcourir la source

BasePool needs on_poll_start. Closes #1364

Ask Solem il y a 12 ans
Parent
commit
8c0d02c59b
1 fichiers modifiés avec 4 ajouts et 1 suppressions
  1. 4 1
      celery/concurrency/base.py

+ 4 - 1
celery/concurrency/base.py

@@ -68,7 +68,10 @@ class BasePool(object):
     def on_stop(self):
         pass
 
-    def on_poll_init(self, w, hub):
+    def on_poll_init(self, worker, hub):
+        pass
+
+    def on_poll_start(self, hub):
         pass
 
     def on_apply(self, *args, **kwargs):