Warum führt Sellerie nur die erste Aufgabe in der Kette?

Question

Ich habe eine funktionierende Kette, aber wenn ich apply_async() hinzufüge, führt es nur die erste Aufgabe aus.

@task(name='run_a', delay=True) 
def run_a(**kwargs): 
    do_whatever(kwarg['var']) 
    return 

@task(name='run_b', delay=True) 
def run_b(**kwargs): 
    # ... 
    return 

@task(name='run_c', delay=True) 
def run_c(**kwargs): 
    # ... 
    return 

Mit einer Kette Befehl:

ret = chain(
    run_a.s(**kwargs), 
    run_b.s(**kwargs), 
    run_b.s(**kwargs) 
).apply_async() 

• Ohne die apply_async alles funktioniert (synchron) wie erwartet.
• 'Kwargs' ist ein Diktat.

Answer 1

Während Sellerie validiert Ihre Aufgaben vor der Ausführung, für eine func *args und **kwargs arbeiten werden erwartet.

# Kwargs was filled, I added an empty args list 
args = [] 
kwargs = { 
    'some': 'intelligent data', 
    } 

Beim Aufruf der Funktionen mit den beiden, es wie erwartet funktioniert:

ret = chain(
    run_a.s(*args, **kwargs), 
    run_b.s(*args, **kwargs), 
    run_b.s(*args, **kwargs) 
).apply_async()