How to delay not exist task by celery?

Question

I have two environments
1. webserver
2. celery worker

webserver add jobs to celery message queue. but those env are separated, so can not import task function.

how to call not exist task explicitly?

ex)

# A project (web) - view.py
def view(request): 
    [X] task_a.delay()  
    [O] add_jobs("task_a", *args)
    ...

# B project (worker) - tasks.py
@task
def task_a:
    ...

Please, give us more details. Improve your question. If you use task.delay(), in your task you have to put a decorator @task, by celery — Paulo Henrique
– Paulo Henrique, Commented Nov 7, 2019 at 16:23

2ps · Accepted Answer · 2019-11-08 05:18:34Z

2

Use the send_task function to send a task to a decoupled celery project.

from celery.app import Celery
app = Celery(broker_url='the broker url of the celery instance')
app.send_task(name='myapp.mytaskname', kwargs={
  'arg1': 'value1',
  'arg2': 'value2',
})

answered Nov 8, 2019 at 5:18

2ps

16k2 gold badges34 silver badges53 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How to delay not exist task by celery?

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related