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())

Вернуться на верх