fix: accumulate all prior task outputs when skipping on checkpoint resume

This commit is contained in:
Greyson LaLonde
2026-04-07 00:48:10 +08:00
parent 3ceeda3aa4
commit 14d5d5bbf8

View File

@@ -160,10 +160,8 @@ def prepare_task_execution(
# Handle replay skip
if start_index is not None and task_index < start_index:
if task.output:
if task.async_execution:
task_outputs.append(task.output)
else:
task_outputs = [task.output]
task_outputs.append(task.output)
if not task.async_execution:
last_sync_output = task.output
return (
TaskExecutionData(agent=None, tools=[], should_skip=True),