添加任务时，关闭原来任务

hhyo · Sep 13, 2024 · c509fe8 · c509fe8
1 parent 4ec80ae
commit c509fe8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sql/sql_workflow.py b/sql/sql_workflow.py
@@ -323,7 +323,8 @@ def execute(request):
             update_fields=["status"]
         )
         # 删除定时执行任务
-        schedule_name = SqlWorkflow(id=workflow_id).timing_task_id
+        workflow_detail = SqlWorkflow.objects.get(id=workflow_id)
+        schedule_name = workflow_detail.timing_task_id
         del_schedule(schedule_name)
         # 加入执行队列
         execute_sql_excute.apply_async(