Celery class based tasks found in the worker, but gets NotRegistered when consumed
I am configuring Celery like that
Why does my celery task status is SUCCESS although it raised an error?
I am trying to use celery but i faced a problem.
I checked in celery_taskmeta table in database and I saw the task status is SUCCESS, but it raise an Error in the log.
Why does my celery task status is SUCCESS although it raised an error?
I am trying to use celery but i faced a problem.
I checked in celery_taskmeta table in database and I saw the task status is SUCCESS, but it raise an Error in the log.
How can I implement live changes in celery beat schedule
I want to write a program with celery beat, where I have a view in postgres which should hold the name of a task, cron expression and some other arguments.
Celery Canvas Workflow in a map reduce style returns a list of IDS instead of the final task result
I am trying to design a kind of map-reduce workflow in Celery where the number of maps comes from another Task result.
celery task is recieved but is not executed
here is main2.py where i have used a model from huggingface
How to handle failures in celery async chain tasks?
I have a chain of celery tasks as shown below. I want to run the on_failure function whenever any task in this chain fails. Currently if any intermediate task fails the main task gets stuck and keeps waiting.
I am using group task because I want to process these tasks in parallel. If there is any other better approach please let me know.
Celery: sending the result of one task to a group of task
I am trying to design a straightforward workflow in Celery: a Father Task that produces some data and returns them, N different children tasks that elaborate the same data coming from the father and return their result.
As a bonus, I would like to process all the children’s results together.