zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: base task_error携带self.name

This commit is contained in:
caoqianming 2024-05-21 13:49:38 +08:00
parent 3ef1985632
commit 102e737729
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/utils/tasks.py
View File

@ -30,7 +30,7 @@ class CustomTask(Task):
detail ='Task {0} raised exception: {1!r}\n{2!r}'.format( detail ='Task {0} raised exception: {1!r}\n{2!r}'.format(
task_id, exc, einfo.traceback) task_id, exc, einfo.traceback)
myLogger.error(detail) myLogger.error(detail)
send_mail_task.delay(subject='task_error', message=detail) send_mail_task.delay(subject=f'task_error_{self.name}', message=detail)
return super().on_failure(exc, task_id, args, kwargs, einfo) return super().on_failure(exc, task_id, args, kwargs, einfo)
@shared_task(base=CustomTask) @shared_task(base=CustomTask)