From 1aa5d3f50743ae5467d191435d7808ec17b93aa1 Mon Sep 17 00:00:00 2001 From: -LAN- Date: Wed, 21 May 2025 19:40:18 +0800 Subject: [PATCH] refactor(workflow_cycle_manager): Removes redundant workflow run retrieval method Signed-off-by: -LAN- --- api/core/workflow/workflow_cycle_manager.py | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/api/core/workflow/workflow_cycle_manager.py b/api/core/workflow/workflow_cycle_manager.py index a57bb49080..9ab9ab0cc8 100644 --- a/api/core/workflow/workflow_cycle_manager.py +++ b/api/core/workflow/workflow_cycle_manager.py @@ -899,19 +899,6 @@ class WorkflowCycleManager: raise WorkflowRunNotFoundError(id) return execution - def _get_workflow_run(self, *, session: Session, workflow_run_id: str) -> WorkflowRun: - if self._workflow_run and self._workflow_run.id == workflow_run_id: - cached_workflow_run = self._workflow_run - cached_workflow_run = session.merge(cached_workflow_run) - return cached_workflow_run - stmt = select(WorkflowRun).where(WorkflowRun.id == workflow_run_id) - workflow_run = session.scalar(stmt) - if not workflow_run: - raise WorkflowRunNotFoundError(workflow_run_id) - self._workflow_run = workflow_run - - return workflow_run - def _handle_agent_log(self, task_id: str, event: QueueAgentLogEvent) -> AgentLogStreamResponse: """ Handle agent log