How are we doing? Please help us improve Stack Overflow. Take our short survey

Questions tagged [celery-task]

celery-task is a building block of Celery distributed task queue system

Filter by
Sorted by
Tagged with
0
votes
0answers
14 views

Celery response queue is consuming but not acknowledging

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 ...
0
votes
0answers
11 views

How to pass an object to celery in django request?

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 ...
-2
votes
1answer
25 views

Is Celery still necessary in Django

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, ...
1
vote
1answer
30 views

Celery - Received unregistered task of type 'core.tasks.scrape_dev_to'

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. File "c:\...
0
votes
0answers
12 views

Celery chain global failure function

I have something like this: @app.task def f1(a, b, c): do_work @app.task def f2(d, e, f): do_another_work @app.task def f(a, b, c, d, e, f): chain = (f1.si(a, b, c) | f2.si(d, e, f)() chain()...
0
votes
3answers
170 views

Celery worker displaying “unknown option -A” on windows

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 ...
0
votes
0answers
15 views

How to wait in the celery beat

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 ...
0
votes
1answer
9 views

Map queue/broker contents to tasks

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 ...
6
votes
2answers
143 views

Celery - how to get task name by task id?

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() cache.save_task_id(res.task_id) ...
0
votes
0answers
14 views

Django/Celery - Object matching query does not exist only when using 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] ...
0
votes
1answer
25 views

How to schedule a celery task through a django view

Is there any way to define a date and time in a django view and run a celery task at the defined time? For example def test(request): date = '2020-09-12' time = '11:34' # run the ...
0
votes
0answers
11 views

Remote chain/group tasks

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 = ...
7
votes
1answer
172 views

How to pause and stop celery task from django template

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 ...
1
vote
1answer
16 views

Assign a specific number of workers for each Celery task in Python

I have three Celery tasks: prediction training healthcheck 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 ...
-1
votes
1answer
43 views

how to import celery tasks in django views

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 ...

15 30 50 per page
1
2 3 4 5
36