Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from celery import chain
- task_chain = chain(
- task_1.s(),
- task_2.s(),
- task_3.s(),
- )
- succeed_callback = [
- task_4.s(),
- task_5.s(),
- ]
- failed_callback = [
- task_6.s(),
- task_7.s(),
- ]
- task_chain.apply_async(
- ...
- link=succeed_callback,
- link_error=failed_callback
- )
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement