Top "Celery" questions

Celery is a distributed task queue framework for Python, used for asynchronous and parallel execution.

Django and Celery - re-loading code into Celery after a change

If I make a change to tasks.py while celery is running, is there a mechanism by which it can …

django celery django-celery
Retry Lost or Failed Tasks (Celery, Django and RabbitMQ)

Is there a way to determine if any task is lost and retry it? I think that the reason for …

rabbitmq celery django-celery
How to write an Ubuntu Upstart job for Celery (django-celery) in a virtualenv

I really enjoy using upstart. I currently have upstart jobs to run different gunicorn instances in a number of virtualenvs. …

django ubuntu celery django-celery upstart
Django and Celery - ModuleNotFoundError: No module named 'celery.task'

I wanted to start a periodic task in Django using Celery. Here are the relevant parts of my project: # celery.…

python django celery periodic-task
How to route a chain of tasks to a specific queue in celery?

When I route a task to a particular queue it works: task.apply_async(queue='beetroot') But if I create …

python rabbitmq celery chain
Cannot start Celery Worker (Kombu.asynchronous.timer)

I followed the first steps with Celery (Django) and trying to run a heavy process in the background. I have …

python python-3.x celery django-celery celery-task
Celery & RabbitMQ running as docker containers: Received unregistered task of type '...'

I am relatively new to docker, celery and rabbitMQ. In our project we currently have the following setup: 1 physical host …

python docker rabbitmq celery amqp
Client unexpectedly closed TCP connection

I have a couple of tasks running as a service. To kick off the worker I use: def SvcDoRun(self): …

python rabbitmq celery rabbitmq-exchange
Celery stop execution of a chain

I have a check_orders task that's executed periodically. It makes a group of tasks so that I can time …

python celery django-celery celery-task celerybeat
How to configure CELERYBEAT_SCHEDULE in Django settings?

I can get this to run as a standalone application, but I am having trouble getting it to work in …

python django celery periodic-task