Questions tagged [celery-task]
celery-task is a building block of Celery distributed task queue system
I have a django application that has a rest endpoint which puts tasks in a queue and waits for the result through a callback.
Unfortunately this leads to the callback function being executed, but the ...
Here i initialize an object which can't be serialized in django view.
I want to share this object among different requests and celery.
Among requests i share the object with middleware.
But I get ...
I'm creating a web app with Django 3.1 and there's lots of DB interactions mostly between three tables. The queries mostly use results that are recent inputs. So query1 will run and update table1, ...
Trying to get a celery-based scraper up and running. The celery worker seems to function on its own, but when I also run the celery beat server, the worker gives me this keyerror.
I have something like this:
def f1(a, b, c):
def f2(d, e, f):
def f(a, b, c, d, e, f):
chain = (f1.si(a, b, c) | f2.si(d, e, f)()
Celery worker suddenly not working and displaying error message saying unknown option -A.
I am running celery 5.0.0 on windows within virtual environment of python.
The command is
pipenv run celery ...
I have celery scheduled tasks for polling an Iot device i.e every 2 seconds. Now sometimes a poll request can take few seconds to respond
What happens is if a response is not received by the tasks, it ...
Is there any way to map the content of messages in the broker/queue to a certain task? I am using SQS and celery for a worker architecture and my workers have python tasks/functions. What I want to do ...
Celery - bottom line: I want to get the task name by using the task id (I don't have a task object)
Suppose I have this code:
res = chain(add.s(4,5), add.s(10)).delay()
I am working with Django and Celery to asynchronously send_mass_mail. When I call the view function that calls the task, I get the following error:
[2020-09-08 17:47:49,148: ERROR/ForkPoolWorker-8] ...
Is there any way to define a date and time in a django view and run a celery task at the defined time?
date = '2020-09-12'
time = '11:34'
# run the ...
dis_vm1 = signature('disconnet_vm',queue='disconnet_vm',kwargs=TaskArgs1, immutable=True)
dis_vm2 = signature('disconnet_vm',queue='disconnet_vm',kwargs=TaskArgs2, immutable=True)
dis_vm3 = ...
I am working on a django application that uses celery to run tasks asynchronously. Right now a user can submit a form from the webpage to start a celery task. But there is no way to pause or stop the ...
I have three Celery tasks:
And I have 4 cpus in the machine. I would like to allocate 3 workers for prediction and training, and 1 for healthcheck. What is the ...
I am learning celery with django. I am trying to create a simple addition project with django and celery. I created a simple webapp with django. in the index.html template, I have a form with 2 input ...