Im working with a django project(im pretty new to django) and running into an issue passing a model object between my view and a celery task. I am taking input from a form which contains several Mo...

Project structure: client nginx web/ celery_worker.py project config.py api/ I have the following services in my docker-compose: version: '3.6' services: web: build: context: ./service...

I've a periodic celery task which needs to store representation of a object in a specific json field. Here is the simplified model structure. Parent <-- ChildWrapper <-- Child Image So basica...

Consider this code: from pydantic import BaseModel class MyModel(BaseModel): x: int appc = Celery(...) @appc.task(bind=True) def mytask(self): return [MyModel(x=0)] res = mytask.delay().get()...

I was reading the documentation of django-channels for the first time today and found the following line Channels will take care of scheduling them and running them all in parallel. Does this mean,...

How to test the tasks of a Celery instance using pytest? I am not talking about testing the Celery tasks created using the @shared_task decorator with pytest. For that, there is already a good solu...

python 3.10 running in venv on Windows 10 pro. I am trying to follow the tutorial for the Celery and Flask integration: https://flask.palletsprojects.com/en/latest/patterns/celery/ # example.py fr...

I have quite a problem with celery on my distribted system. I have couple of machines among different localizations and I've got a lot of warnings in my log files like: "Substantial drift from cel...

This is probably a stupid question but its got me stumped coming from a Ruby background. I have an object that looks like this when I try to print it. print celery.AsyncResult.task_id >>&gt...

I am trying to get started with celery, but I can't get my task up and running. I have installed django-celery-beat and celery4. My settings file. Installed apps (with celery packages) ... 'djan...

I've been trying to figure out this for a while but a lot of answers I can find now are out-dated (posts from > 6 years ago), or less related. The question is really how to deal with database se...

I'm learning Django. recently I tried to use celery. the problem that I'm facing with it is tasks are receiving but they don't execute. settings.py: # Celery application definition CELERY_BROKER_UR...

I have a task, somewhat like this: @task() def async_work(info): ... At any moment, I may call async_work with some info. For some reason, I need to make sure that only one async_work is running ...

What is the point of Celery chain if the whole chain breaks if one of the tasks fail?!! I have this Celery chain: res = chain(workme.s ( y=1111 ), workme2.s( 2222 ), workme3.s( 3333 ),)() And ...

Although celery reports no problems at start and says it successfully connected to redis (see log), I get this error running celery inspect ping Traceback (most recent call last): File "/usr/...

I just switched from ForkPool to gevent with concurrency (5) as the pool method for Celery workers running in Kubernetes pods. After the switch I've been getting a non recoverable erro in the worke...

How can I create a wrapper that makes celery tasks look like asyncio.Task? Or is there a better way to integrate Celery with asyncio? @asksol, the creator of Celery, said this:: It's quite comm...

I am using VSCode for web-developing with framework Django. There is no questions for debugging Django, but when i try to use Celery - debugger dosn't stop at breakpoints. I use this configuration ...

I have an app that was written with Flask+SQLALchemy+Celery, RabbitMQ as a broker, database is PostgreSQL (PostgreSQL 10.11 (Ubuntu 10.11-1.pgdg16.04+1) on x86_64-pc-linux-gnu, compiled by gcc (Ubu...

I have an API build with FastAPI which endpoint submits a task to a celery worker, waits for worker to finish its job and return a result to the user. Question is what is the correct way to wait th...

I use Celery with RabbitMQ in my Django app (on Elastic Beanstalk) to manage background tasks and I daemonized it using Supervisor. The problem now, is that one of the period task that I defined is...

I use celery 4.4.0 version in my project(Ubuntu 18.04.2 LTS). When i raise Exception('too few functions in features to classify') , celery project lost worker and i get such logs: [2020-02-11 15:4...

While issuing a new build to update code in workers how do I restart celery workers gracefully? Edit: What I intend to do is to something like this. Worker is running, probably uploading a 100 ...

My application is written in django f/w which uses celery and redis for asynchronous tasks. I would like to autoscale workers according load/no.of messages in queue. For this, I would like to make ...

We upgrade Celery and started to get a warning: CPendingDeprecationWarning: The broker_connection_retry configuration setting will no longer determine whether broker connection retries are made du...