Где вы устанавливаете идентификатор задачи _задачи celery?

У меня возникли проблемы с поиском примера установки идентификатора задачи _с моей собственной задачей _id

something по этим линиям...

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
9
задан michael 19 April 2012 в 19:13
поделиться