You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
21 lines
615 B
21 lines
615 B
from celery import Task
|
|
|
|
|
|
class HookTask(Task):
|
|
"""
|
|
任务钩子： 监控任务的执行
|
|
"""
|
|
|
|
# 成功时执行
|
|
def on_success(self, ret_val, task_id, args, kwargs):
|
|
print('ret_val', ret_val)
|
|
print(f'task id:{task_id} , arg:{args} , successful !')
|
|
|
|
# 失败时执行
|
|
def on_failure(self, exc, task_id, args, kwargs, error_info):
|
|
print(f'task id:{task_id} , arg:{args} , failed ! errors: {exc}')
|
|
|
|
# 任务重试时执行
|
|
def on_retry(self, exc, task_id, args, kwargs, error_info):
|
|
print(f'task id:{task_id} , arg:{args} , retry ! errors: {exc}')
|