Top "Celery" questions

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

How does a Celery worker consuming from multiple queues decide which to consume from first?

I am using Celery to perform asynchronous background tasks, with Redis as the backend. I'm interested in the behaviour of …

scheduled-tasks celery celeryd
Celery: Worker with concurrency and reserved tasks only running 1 task

Some of the tasks in my code were taking longer and longer to execute. Upon inspection I noticed that although …

concurrency celery django-celery
Celery beat schedule multiple tasks under same time-interval group

I'm trying to set up two tasks that both run every minute. Is there any way to group them in …

python flask celery celerybeat
Difficulty with Celery: function object has no property 'delay'

I have been churning through the software development recently and have had some success bending celery to my will. I …

python python-2.7 flask celery flask-security
How to check if Celery/Supervisor is running using Python

How to write a script in Python that outputs if celery is running on a machine (Ubuntu)? My use-case. I …

python flask celery supervisord
Celery Tasks Not Being Processed

I'm trying to process some tasks using celery, and I'm not having too much luck. I'm running celeryd and celerybeat …

python rabbitmq task celery broker
Get the name of celery worker from inside a celery task?

I'd like a celery task to be able to get the name of the worker executing it, for logging purposes. …

python celery celery-task
Running celery worker + beat in the same container

My flask app is comprised of four containers: web app, postgres, rabbitMQ and Celery. Since I have celery tasks that …

python docker flask celery celerybeat
ImportError: cannot import name 'Command' from 'celery.bin.base'

When I run the command flower -A main --port=5555 Flower doesn't work, the error is: > ImportError: cannot import name …

python celery flower
Increase celery retry time each retry cycle

I do retries with celery like in the Docs-Example: @task() def add(x, y): try: ... except Exception, exc: add.retry(…

python celery celeryd