Celery Canvas not executing callback jobs

Viewed 12

I'm trying to create a multi-level Celery jobs canvas using the following code:

job = chain(chord(group(job_list),
                      update_job_status.si(job_id_list, success=True).on_error(
                          update_job_status.si(job_id_list, success=False))),
                final_follow_up_job.si(job_id_list))
job.apply_async()

But the final level of jobs (update_job_status, final_follow_up_job) aren't getting called. No errors in the job_list jobs.

Python v3.9, Celery v5.1.2

0 Answers
Related