From 65ff80db75369673155805122a1711f696d6df2d Mon Sep 17 00:00:00 2001 From: caoqianming Date: Fri, 14 Apr 2023 16:53:35 +0800 Subject: [PATCH] =?UTF-8?q?refector:=20=E5=B7=A5=E4=BD=9C=E6=B5=81?= =?UTF-8?q?=E8=84=9A=E6=9C=AC=E6=AF=8F=E6=AC=A1=E5=A4=B1=E8=B4=A5=E9=83=BD?= =?UTF-8?q?=E8=AE=B0=E5=BD=95=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/wf/tasks.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/wf/tasks.py b/apps/wf/tasks.py index d7a1a54f..b6304470 100644 --- a/apps/wf/tasks.py +++ b/apps/wf/tasks.py @@ -49,14 +49,14 @@ def run_task(ticket_id: str, retry_num=1): f(ticket) except Exception: retry_num_new = retry_num - 1 - if retry_num_new >= 0: - time.sleep(10) - run_task.delay(ticket_id, retry_num_new) - return err_detail = traceback.format_exc() myLogger.error('工作流脚本执行失败', exc_info=True) script_result = False script_result_msg = err_detail + if retry_num_new >= 0: + time.sleep(10) + run_task.delay(ticket_id, retry_num_new) + return send_mail_task.delay(subject='wf_task_error', message=err_detail) # run_task执行失败发送邮件 ticket = Ticket.objects.filter(id=ticket_id).first() if not script_result: