Tracking-Sellerie-Job Fortschritte in Haupt

Question

ich eine Reihe von Aufgaben in Sellerie Start:

jobs = [some_task.delay(*arg) for arg in args] 
results = jobs.get() 

Gibt es eine Möglichkeit der kontinuierlich die Anzahl der Aufgaben aus dem Haupt-Thread oder auf andere Weise beendet die Ausgabe, das heißt:

while tasks_still_running: 
    print "Completed %s of %s tasks." % (num_complete, len(jobs)) 
    time.sleep(1) 

Answer 1

Sie können Sellerie Signale für diesen Einsatz:

from celery.signals import task_success 
@task_success.connect() 
def tasks_success_callback(signal, result, sender): 
    print result