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: