5
我有这样的任务芹菜:如何手动将Celery任务标记为完成并设置其结果?
@app.task
def do_something(with_this):
# instantiate a class from a third party library
instance = SomeClass()
# this class uses callbacks to send progress info about
# the status and progress of what we're doing
def progress_callback(data):
# this status will change to 'finished' later
# but the return value that I want as the task result won't be returned
# so this is where I should mark the task as done manually
if data['status'] == 'working':
# I create a custom state for this task
do_something.update_state(
state = 'PROGRESS',
meta = data['progress']
)
# adding the callback to the instance
instance.add_callback(progress_callback)
# use the instance to do what I want
# this functions returns a value that I don't want as the task result
# so leaving this function without a return statement will make it None
instance.do_job(with_this)
我怎么能任务标记为手动完成?
在这种情况下,函数到达最后而没有任何return
语句,因此我得到的task.result
是None
,我想设置传递给回调函数的数据作为结果并将任务标记为完成。
我试着使用:
app.backend.mark_as_done(do_something.request.id, data)
它成功设置状态和任务的结果,但后来的结果被设定为是这里None
函数的返回值。