GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-09-05 15:38:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix workflow

Browse Source
This commit is contained in:
jxxghp
2025-02-17 15:08:24 +08:00
parent 6c233f13de
commit e5a4d11cf9
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/chain/workflow.py
+3 -2
View File
@@ -4,7 +4,7 @@ from app.chain import ChainBase
from app.core.workflow import WorkFlowManager from app.core.workflow import WorkFlowManager
from app.db.workflow_oper import WorkflowOper from app.db.workflow_oper import WorkflowOper
from app.log import logger from app.log import logger
from app.schemas import Workflow, ActionContext from app.schemas import Workflow, ActionContext, Action
class WorkflowChain(ChainBase): class WorkflowChain(ChainBase):
@@ -32,7 +32,8 @@ class WorkflowChain(ChainBase):
# 启用上下文 # 启用上下文
context = ActionContext() context = ActionContext()
self.workflowoper.start(workflow_id) self.workflowoper.start(workflow_id)
for action in workflow.actions: for act in workflow.actions:
action = Action(**act)
state, context = self.workflowmanager.excute(action, context) state, context = self.workflowmanager.excute(action, context)
self.workflowoper.step(workflow_id, action=action.name, context=context.dict()) self.workflowoper.step(workflow_id, action=action.name, context=context.dict())
if not state: if not state: