Przeglądaj źródła

Add actor by id or name using the broadcast command
(Note that this is a temporary command, the actors should be added using a call to the actors_manager)

Rumyana Neykova 12 lat temu
rodzic
commit
1220161fee
1 zmienionych plików z 4 dodań i 6 usunięć
  1. 4 6
      celery/worker/control.py

+ 4 - 6
celery/worker/control.py

@@ -51,7 +51,6 @@ def revoke(panel, task_id, terminate=False, signal=None, **kwargs):
     logger.info('Task %s %s.', task_id, action)
     logger.info('Task %s %s.', task_id, action)
     return {'ok': 'task {0} {1}'.format(task_id, action)}
     return {'ok': 'task {0} {1}'.format(task_id, action)}
 
 
-
 @Panel.register
 @Panel.register
 def report(panel):
 def report(panel):
     return {'ok': panel.app.bugreport()}
     return {'ok': panel.app.bugreport()}
@@ -279,10 +278,9 @@ def dump_conf(panel, **kwargs):
     return jsonify(dict(panel.app.conf))
     return jsonify(dict(panel.app.conf))
 
 
 @Panel.register
 @Panel.register
-def start_actor(panel, name):
-    print name
-    return panel.consumer.add_actor(name)
+def start_actor(panel, name, actor_id):
+    return panel.consumer.add_actor(name, actor_id)
 
 
 @Panel.register
 @Panel.register
-def stop_actor(panel, id):
-    return panel.consumer.stop_actor(id)
+def stop_actor(panel, actor_id):
+    return panel.consumer.stop_actor(actor_id)