Top "Celery" questions

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

ImportError: No module named timeutils

I trying to follow tutorial install of django-celery. After install i need run migrate to make the necessary tables but …

python django celery django-celery
How to put a rate limit on a celery queue?

I read this in the celery documentation for Task.rate_limit: Note that this is a per worker instance rate …

celery
Recover from task failed beyond max_retries

I am attempting to asynchronously consume a web service because it takes up to 45 seconds to return. Unfortunately, this web …

django celery django-celery
on building docker image level=error msg="Can't close tar writer: io: read/write on closed pipe"

time="2017-10-27T07:39:20Z" level=error msg="Can't add file /var/app/current/app/content_classifier/forest.pickle to …

linux docker celery amazon-elastic-beanstalk celerybeat
Airflow + celery or dask. For what, when?

I read in the official Airflow documentation the following: What does this mean exactly? What do the authors mean by …

celery dask airflow
How do I enable remote celery debugging in PyCharm?

I'm trying to find some instructions on how to enable PyCharm debugging within my celery processes on a remote machine. …

debugging celery pycharm
How many CPU cores has a heroku dyno?

I'm using Django with Celery 3.0.17 and now trying to figure out how many celery workers are run by default. From …

heroku cpu celery cpu-cores
Celery: is there a way to write custom JSON Encoder/Decoder?

I have some objects I want to send to celery tasks on my application. Those objects are obviously not json …

python json celery
kombu.exceptions.EncodeError: User is not JSON serializable

I have django 1.11.5 app with celery 4.1.0 and I recived all the time: kombu.exceptions.EncodeError: <User: testuser> is …

python json django celery celery-task
Django & Celery — Routing problems

I'm using Django and Celery and I'm trying to setup routing to multiple queues. When I specify a task's routing_…

django celery django-celery kombu