Browse Source

Add broadcast command for starting actors.
(this is redundant with the actors component, but is useful for now)

Rumyana Neykova 13 năm trước cách đây
mục cha
commit
0ac876041a
1 tập tin đã thay đổi với 5 bổ sung2 xóa
  1. 5 2
      celery/app/control.py

+ 5 - 2
celery/app/control.py

@@ -139,8 +139,11 @@ class Control(object):
         return self.broadcast('ping', reply=True, destination=destination,
                               timeout=timeout, **kwargs)
 
-    def start_actor(self, actor_name, destination = None, timeout = 1, **kwargs):
-        return self.broadcast('start_actor', name = actor_name, reply=True, destination=destination,
+    def start_actor(self, actor_name, actor_id = None, 
+                    destination = None, timeout = 1, **kwargs):
+        return self.broadcast('start_actor', name = actor_name, 
+                              actor_id = actor_id, 
+                              reply=True, destination=destination,
                               timeout=timeout, **kwargs)
         
     def rate_limit(self, task_name, rate_limit, destination=None, **kwargs):