From 9ff62a7b57ed8f36e888250dbf752dfe0826f694 Mon Sep 17 00:00:00 2001 From: nick2wang Date: Tue, 28 Dec 2021 18:08:03 +0800 Subject: [PATCH] Update sql_workflow.py MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 修复手动执行完成的工单没有发送通知的问题#1284 --- sql/sql_workflow.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/sql/sql_workflow.py b/sql/sql_workflow.py index ca7aaf79ed..b465f082c7 100644 --- a/sql/sql_workflow.py +++ b/sql/sql_workflow.py @@ -17,7 +17,7 @@ from common.utils.const import Const, WorkflowDict from common.utils.extend_json_encoder import ExtendJSONEncoder from sql.engines.models import ReviewResult, ReviewSet -from sql.notify import notify_for_audit +from sql.notify import notify_for_audit, notify_for_execute from sql.models import ResourceGroup from sql.utils.resource_group import user_groups, user_instances from sql.utils.tasks import add_sql_schedule, del_schedule @@ -424,6 +424,8 @@ def execute(request): operation_info='确认手工执行结束', operator=request.user.username, operator_display=request.user.display) + # 发送消息 + notify_for_execute(SqlWorkflow.objects.get(id=workflow_id)) return HttpResponseRedirect(reverse('sql:detail', args=(workflow_id,)))