Advertisement
Guest User

Untitled

a guest
Jan 12th, 2021
46
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 0.32 KB | None | 0 0
  1. from celery import chain
  2.  
  3. task_chain = chain(
  4.       task_1.s(),
  5.       task_2.s(),
  6.       task_3.s(),
  7.   )
  8.  
  9. succeed_callback = [
  10.     task_4.s(),
  11.     task_5.s(),
  12. ]
  13.  
  14. failed_callback = [
  15.     task_6.s(),
  16.     task_7.s(),
  17. ]
  18.  
  19. task_chain.apply_async(
  20.     ...
  21.     link=succeed_callback,
  22.     link_error=failed_callback
  23. )
  24.    
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement