Kereviz neden zincirdeki ilk görevi yürütüyor?

Question

Bir çalışan zincirim var, ancak apply_async() eklediğimde yalnızca ilk görevi yürütüyor. beklendiği gibi apply_async tüm eserlerin (eşzamanlı) olmadan

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

• : Bir zincir komutla

  @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 
  

  .

• 'kwargs' bir hakemdir. Bir işlev *args ve **kwargs beklenmektedir çalışması için

Answer 1

Kereviz, çalıştırılmadan önce görevlerinizi doğrular iken.

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