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

refector: 工作流脚本每次失败都记录日志

This commit is contained in:
caoqianming 2023-04-14 16:53:35 +08:00
parent 2d2f171c32
commit 65ff80db75
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/wf/tasks.py
View File

@ -49,14 +49,14 @@ def run_task(ticket_id: str, retry_num=1):
f(ticket) f(ticket)
except Exception: except Exception:
retry_num_new = retry_num - 1 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() err_detail = traceback.format_exc()
myLogger.error('工作流脚本执行失败', exc_info=True) myLogger.error('工作流脚本执行失败', exc_info=True)
script_result = False script_result = False
script_result_msg = err_detail 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执行失败发送邮件 send_mail_task.delay(subject='wf_task_error', message=err_detail) # run_task执行失败发送邮件
ticket = Ticket.objects.filter(id=ticket_id).first() ticket = Ticket.objects.filter(id=ticket_id).first()
if not script_result: if not script_result: