Wo setzen Sie die Task-ID einer Sellerie-Aufgabe?

Question

Ich habe Probleme kein Beispiel finden

etwas in diese Richtung eine task_id mit meinem eigenen task_id Einstellung ...

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 

Answer 1

Verzögerung keine Optionen unterstützt, ist es eine Verknüpfung apply_async:

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

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

Auch die ID der aktuellen Aufgabe ist in task.request.id nicht task.id wie Sie oben haben.