I have used Celery for a while now (not Django involved), but all of my tasks have always been defined in one main tasks.py file like this:

I am working on a distributed processing application that I need to be as fast as possible. I have a deployment where a leader application writes celery tasks to redis and have N listening workers to execute the task.

I am working on a distributed processing application that I need to be as fast as possible. I have a deployment where a leader application writes celery tasks to redis and have N listening workers to execute the task.

I am working on a distributed processing application that I need to be as fast as possible. I have a deployment where a leader application writes celery tasks to redis and have N listening workers to execute the task.

I am working on a distributed processing application that I need to be as fast as possible. I have a deployment where a leader application writes celery tasks to redis and have N listening workers to execute the task.

I want to ask a question regarding the usage of max_tries with the options reject_on_worker_lost=True and ack_late=True.

Need to combine one audio track with several videos, currently there is a problem that the audio track is loaded several times.

Need to combine one audio track with several videos, currently there is a problem that the audio track is loaded several times.

Celery allow to route tasks by task-name to avoid a load from a kind of task to delay tasks from other kinds.

I have some Celery workers up and running, which use RabbitMQ as message broker. Everything works find and tasks are being processed.