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

Clean up failure reason in block errors (#1962)

Browse Source
This commit is contained in:
Shuchang Zheng
2025-03-17 21:26:01 -07:00
committed by GitHub
parent eb3db8187e
commit 660e1c581e
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -370,7 +370,9 @@ class WorkflowService:
block_label=block.label, block_label=block.label,
) )
if not block.continue_on_failure: if not block.continue_on_failure:
failure_reason = f"Block with type {block.block_type} at index {block_idx}/{blocks_cnt - 1} failed. failure reason: {block_result.failure_reason}" failure_reason = (
f"{block.block_type} block failed. failure reason: {block_result.failure_reason}"
)
await self.mark_workflow_run_as_failed( await self.mark_workflow_run_as_failed(
workflow_run_id=workflow_run.workflow_run_id, failure_reason=failure_reason workflow_run_id=workflow_run.workflow_run_id, failure_reason=failure_reason
) )
@@ -406,7 +408,7 @@ class WorkflowService:
) )
if not block.continue_on_failure: if not block.continue_on_failure:
failure_reason = f"Block with type {block.block_type} at index {block_idx}/{blocks_cnt - 1} terminated. Reason: {block_result.failure_reason}" failure_reason = f"{block.block_type} block terminated. Reason: {block_result.failure_reason}"
await self.mark_workflow_run_as_terminated( await self.mark_workflow_run_as_terminated(
workflow_run_id=workflow_run.workflow_run_id, failure_reason=failure_reason workflow_run_id=workflow_run.workflow_run_id, failure_reason=failure_reason
) )
@@ -442,7 +444,7 @@ class WorkflowService:
) )
if not block.continue_on_failure: if not block.continue_on_failure:
failure_reason = f"Block with type {block.block_type} at index {block_idx}/{blocks_cnt - 1} timed out. Reason: {block_result.failure_reason}" failure_reason = f"{block.block_type} block timed out. Reason: {block_result.failure_reason}"
await self.mark_workflow_run_as_failed( await self.mark_workflow_run_as_failed(
workflow_run_id=workflow_run.workflow_run_id, failure_reason=failure_reason workflow_run_id=workflow_run.workflow_run_id, failure_reason=failure_reason
) )
@@ -479,7 +481,7 @@ class WorkflowService:
if isinstance(e, SkyvernException): if isinstance(e, SkyvernException):
exception_message = f"unexpected SkyvernException({e.__class__.__name__}): {str(e)}" exception_message = f"unexpected SkyvernException({e.__class__.__name__}): {str(e)}"
failure_reason = f"Block with type {block.block_type} at index {block_idx}/{blocks_cnt - 1} failed. failure reason: {exception_message}" failure_reason = f"{block.block_type} block failed. failure reason: {exception_message}"
await self.mark_workflow_run_as_failed( await self.mark_workflow_run_as_failed(
workflow_run_id=workflow_run.workflow_run_id, failure_reason=failure_reason workflow_run_id=workflow_run.workflow_run_id, failure_reason=failure_reason
) )