DAG Coordination
Manage the full lifecycle of architect plan execution through the DAG scheduler.
Capabilities
- •Execute DAGs from architect plan dispatch (via bus or direct skill invocation)
- •Cancel running DAGs with reason tracking
- •Modify running DAGs mid-flight (add/remove nodes) at architect request
- •Query DAG status from the live scheduler or historical SQLite store
- •Recover incomplete DAGs after crash via WAL replay
Decision framework
DAG execution request
- •Execute via
execute_dagwith the plan's DAG JSON - •Monitor progress via
query_dag_status - •Query pipeline agent buffers via
query_bufferfor per-task detail - •On completion or failure, broadcast status
DAG modification
- •Apply via
modify_dagwith the architect's modification payload - •Monitor the modified DAG for stability via
query_dag_status
DAG failure
- •Query status via
query_dag_status - •Query task buffers for failed nodes via
query_buffer - •Escalate to architect with failure context via
escalate_to_architect
Skill reference
| Skill | Purpose |
|---|---|
execute_dag | Submit DAG to scheduler for async execution |
cancel_dag | Cancel a running DAG with reason |
modify_dag | Add/remove nodes mid-flight |
query_dag_status | Get live or historical DAG status |