-
Notifications
You must be signed in to change notification settings - Fork 2
feat(orchestration): Phase 5 — Aggregator + resume/retry #1240
Copy link
Copy link
Closed
Labels
enhancementNew feature or requestNew feature or requestorchestrationTask orchestration / DAG schedulingTask orchestration / DAG scheduling
Description
Parent: #1235
Blocked by: #1239
Summary
Implement result aggregation and graph lifecycle management (resume paused graphs, retry failed tasks).
Branch: feat/m33/orchestration-aggregator
Deliverables
New files
crates/zeph-core/src/orchestration/aggregator.rs—Aggregatortrait +LlmAggregatorimpl
Modified files
crates/zeph-core/src/orchestration/command.rs— add/plan resume,/plan retry
Aggregator
- Concatenates
TaskResult.outputfrom all completed tasks - Calls LLM with
aggregator_max_tokensto synthesize coherent final response - Handles graphs with skipped tasks (mentions them in synthesis)
- Uses
planner_modelconfig (or agent's primary model)
Resume/Retry
/plan resume— unpauses a graph inPausedstate (fromAskfailure strategy), continues scheduling/plan retry— re-runs failed tasks in aFailedgraph by resetting them toReady
Tests (~10)
- Aggregator produces coherent output from multiple task results
- Aggregator handles graphs with skipped tasks
- Aggregator handles single-task graph
- Resume unpauses and continues scheduling
- Resume on non-paused graph returns error
- Retry resets failed tasks and re-runs
- Retry on non-failed graph returns error
Dependencies
Blocked by: Phase 4 (#1239)
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
enhancementNew feature or requestNew feature or requestorchestrationTask orchestration / DAG schedulingTask orchestration / DAG scheduling