我使用celery ^{
from celery import Task
class DebugTask(Task):
abstract = True
def after_return(self, *args, **kwargs):
print('Task returned: {0!r}'.format(self.request))
def on_failure(self, exc, task_id, args, kwargs, einfo):
func_name = get_func_name_by_task_id(task_id) # how do I do this?
print "{} failed".format(func_name) # expected out: add failed.
@app.task(base=DebugTask)
def add(x, y):
return x + y
PS:我知道有task_id
,但每次按task_id
查询函数名并不好玩
快速查看文档显示^{} 。在
相关问题 更多 >
编程相关推荐