2012-04-19 20 views
9

मैं मुसीबत मेरे अपने task_id के साथ इन पंक्तियों के साथआप एक अजवाइन कार्य के task_id कहां सेट करते हैं?

कुछ एक task_id स्थापित करने के किसी भी उदाहरण खोजने हो रहा है ...

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 

उत्तर

20

देरी विकल्प का समर्थन नहीं करता है, यह apply_async के लिए एक शॉर्टकट है:

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

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

इसके अलावा वर्तमान कार्य की आईडी task.request.idtask.id जैसी नहीं है जैसा कि आप ऊपर हैं।

+0

धन्यवाद! मेरे पास एक और सवाल है जिसके साथ आप मेरी मदद कर सकते हैं। – michael

+0

http://stackoverflow.com/questions/10238477/mopping-up-after-celery-results-when-stored-in-db – michael

 संबंधित मुद्दे

  • कोई संबंधित समस्या नहीं^_^