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

fix task v2 post action script gen - update workflow definition before execution the generated block (#3589)

Browse Source
This commit is contained in:
Shuchang Zheng
2025-10-01 20:02:30 -07:00
committed by GitHub
parent 696fcc56a0
commit dc2a1e8f55
1 changed files with 19 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
skyvern/services/task_v2_service.py
View File

@@ -770,26 +770,6 @@ async def run_task_v2_helper(
failure_reason=f"Unsupported task block type gets generated: {task_type}", failure_reason=f"Unsupported task block type gets generated: {task_type}",
) )
break break
# generate the extraction task
block_result = await block.execute_safe(
workflow_run_id=workflow_run_id,
organization_id=organization_id,
code_gen=code_gen,
)
task_history_record["status"] = str(block_result.status)
if block_result.failure_reason:
task_history_record["reason"] = block_result.failure_reason
extracted_data = _get_extracted_data_from_block_result(
block_result,
task_type,
task_v2_id=task_v2_id,
workflow_run_id=workflow_run_id,
)
if extracted_data is not None:
task_history_record["extracted_data"] = extracted_data
task_history.append(task_history_record)
# refresh workflow # refresh workflow
yaml_blocks.extend(block_yaml_list) yaml_blocks.extend(block_yaml_list)
yaml_parameters.extend(parameter_yaml_list) yaml_parameters.extend(parameter_yaml_list)
@@ -816,6 +796,25 @@ async def run_task_v2_helper(
) )
LOG.info("Workflow created", workflow_id=workflow.workflow_id) LOG.info("Workflow created", workflow_id=workflow.workflow_id)
# generate the extraction task
block_result = await block.execute_safe(
workflow_run_id=workflow_run_id,
organization_id=organization_id,
code_gen=code_gen,
)
task_history_record["status"] = str(block_result.status)
if block_result.failure_reason:
task_history_record["reason"] = block_result.failure_reason
extracted_data = _get_extracted_data_from_block_result(
block_result,
task_type,
task_v2_id=task_v2_id,
workflow_run_id=workflow_run_id,
)
if extracted_data is not None:
task_history_record["extracted_data"] = extracted_data
task_history.append(task_history_record)
# execute the extraction task # execute the extraction task
workflow_run = await handle_block_result( workflow_run = await handle_block_result(
task_v2_id, task_v2_id,