Where do you set the task_id of a celery task?

Question

I am having trouble finding any example of setting a task_id with my own task_id

something along these lines...

def testview1(request):
    for i in xrange(0,1000):
        result = add.delay( i, 4,task_id = i)
        print result.info
        #value = result.wait()
    return HttpResponse("Done") 


@task()
def add(task_id, x, y):
    print add.task_id
    print str(x+y)
    return x + y

score 42 · Accepted Answer · answered Apr 19 '12 at 22:19

42

delay doesn't support options, it's a shortcut to apply_async:

add.apply_async(args, kwargs, task_id=i)

add.apply_async((1, 4), task_id=i)

Also the id of the current task is in task.request.id not task.id like you have above.

answered Apr 19 '12 at 22:19

asksol

19,129
5
61
68

Thanks! I have another question you may be able to help me with. – michael Apr 19 '12 at 23:55
http://stackoverflow.com/questions/10238477/mopping-up-after-celery-results-when-stored-in-db – michael Apr 19 '12 at 23:56
This is super handy! – Shiplu Mokaddim Jul 26 '19 at 14:19

Where do you set the task_id of a celery task?

1 Answers1

Linked