vodorod/Dorod-Sky
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix workflow run timeline infinite loop (#1431)

Browse Source
This commit is contained in:
Shuchang Zheng
2024-12-23 13:37:30 -08:00
committed by GitHub
parent acbdcb14e3
commit 682bc717f9
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
skyvern/forge/sdk/workflow/service.py
View File

@@ -1630,7 +1630,9 @@ class WorkflowService:
result = [] result = []
block_map: dict[str, WorkflowRunTimeline] = {} block_map: dict[str, WorkflowRunTimeline] = {}
counter = 0
while workflow_run_blocks: while workflow_run_blocks:
counter += 1
block = workflow_run_blocks.pop(0) block = workflow_run_blocks.pop(0)
workflow_run_timeline = WorkflowRunTimeline( workflow_run_timeline = WorkflowRunTimeline(
type=WorkflowRunTimelineType.block, type=WorkflowRunTimelineType.block,
@@ -1646,5 +1648,10 @@ class WorkflowService:
workflow_run_blocks.append(block) workflow_run_blocks.append(block)
else: else:
result.append(workflow_run_timeline) result.append(workflow_run_timeline)
block_map[block.workflow_run_block_id] = workflow_run_timeline
if counter > 1000:
LOG.error("Too many blocks in the workflow run", workflow_run_id=workflow_run_id)
break
return result return result