Celery chord callback executes before tasks completes
I have a celery workflow, as presented in the above image. I am facing a scenario where the parent_task_callback is executed before all the sub_parent_task callbacks are executed. None of these tasks has ignore_result set to false nor have I globally set it to false. What am I missing?
The code looks like this:
@app.task
def sub_parent_task():
chord(child_tasks_list)(sub_parent_task_callback.si())
@app.task
def parent_task():
chord(sub_parent_tasks_list)(parent_task_callback.si())