feat: base task_error携带self.name

2024-05-21 13:49:38 +08:00 · 2024-05-21 13:49:38 +08:00 · 2ed77b9f0f
parent cdfa35851d
commit 2ed77b9f0f
1 changed files with 1 additions and 1 deletions
--- a/apps/utils/tasks.py
+++ b/apps/utils/tasks.py
@ -30,7 +30,7 @@ class CustomTask(Task):
        detail ='Task {0} raised exception: {1!r}\n{2!r}'.format(
                    task_id, exc, einfo.traceback)
        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)

@shared_task(base=CustomTask)