GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-09-06 07:56:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix bug

Browse Source
This commit is contained in:
jxxghp
2025-07-22 21:02:02 +08:00
parent f61cd969b9
commit 924f59afff
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/api/endpoints/workflow.py
+4 -4
View File
@@ -199,7 +199,7 @@ def start_workflow(workflow_id: int,
workflow = WorkflowOper(db).get(workflow_id) workflow = WorkflowOper(db).get(workflow_id)
if not workflow: if not workflow:
return schemas.Response(success=False, message="工作流不存在") return schemas.Response(success=False, message="工作流不存在")
if not workflow.event_type or workflow.event_type == "timer": if not workflow.trigger_type or workflow.trigger_type == "timer":
# 添加定时任务 # 添加定时任务
Scheduler().update_workflow_job(workflow) Scheduler().update_workflow_job(workflow)
else: else:
@@ -278,8 +278,8 @@ def update_workflow(workflow: schemas.Workflow,
wf = WorkflowOper(db).get(workflow.id) wf = WorkflowOper(db).get(workflow.id)
if not wf: if not wf:
return schemas.Response(success=False, message="工作流不存在") return schemas.Response(success=False, message="工作流不存在")
if not wf.event_type: if not wf.trigger_type:
workflow.event_type = "timer" workflow.trigger_type = "timer"
wf.update(db, workflow.dict()) wf.update(db, workflow.dict())
return schemas.Response(success=True, message="更新成功") return schemas.Response(success=True, message="更新成功")
@@ -294,7 +294,7 @@ def delete_workflow(workflow_id: int,
workflow = WorkflowOper(db).get(workflow_id) workflow = WorkflowOper(db).get(workflow_id)
if not workflow: if not workflow:
return schemas.Response(success=False, message="工作流不存在") return schemas.Response(success=False, message="工作流不存在")
if not workflow.event_type or workflow.event_type == "timer": if not workflow.trigger_type or workflow.trigger_type == "timer":
# 定时触发：删除定时任务 # 定时触发：删除定时任务
Scheduler().remove_workflow_job(workflow) Scheduler().remove_workflow_job(workflow)
else: else: