12

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
4

1 に答える 1

32

delayはオプションをサポートしていません。apply_asyncへのショートカットです。

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

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

また、現在のタスクのIDは、上記のようにはなりtask.request.idません。task.id

于 2012-04-19T22:19:58.593 に答える