zag-orch

Orchestration library for zag — multi-session coordination for AI coding agents.

Overview

zag-orch provides the Rust implementation behind zag's orchestration CLI commands. It is the programmatic layer for launching, synchronizing, and collecting results from multiple agent sessions.

This crate depends on zag (zag-agent) for shared types and agent execution.

Modules

Session lifecycle

Module	CLI command	Description
`spawn`	`zag spawn`	Launch a background agent session, return session ID
`cancel`	`zag cancel`	Graceful session cancellation with clean log entry
`retry`	`zag retry`	Re-run failed sessions with the same configuration
`gc`	`zag gc`	Clean up old session data, logs, and process entries

Coordination

Module	CLI command	Description
`wait`	`zag wait`	Block until session(s) complete
`collect`	`zag collect`	Gather results from multiple sessions
`pipe`	`zag pipe`	Chain session results into a new agent session
`status`	`zag status`	Machine-readable session health check

Observation

Module	CLI command	Description
`events`	`zag events`	Structured event query API for session logs
`listen`	`zag listen`	Session log tailing and event formatting
`watch`	`zag watch`	Event-driven reactions on session log events
`subscribe`	`zag subscribe`	Multiplexed event stream from all active sessions
`summary`	`zag summary`	Log-based session summarization and stats
`output_cmd`	`zag output`	Extract final result text from sessions
`log_cmd`	`zag log`	Append custom structured events to session logs
`search`	`zag search`	CLI argument wiring for session log search

Introspection

Module	CLI command	Description
`ps`	`zag ps`	List, inspect, and kill agent processes
`whoami`	`zag whoami`	Session identity introspection via env vars
`env`	`zag env`	Export session environment variables
`lifecycle`	(internal)	Filesystem lifecycle markers (`.started`/`.ended`)

Usage

Most users interact with these primitives through the zag CLI. Library consumers who need orchestration beyond AgentBuilder can depend on this crate directly:

[dependencies]
zag-orch = "0.1"
zag = "0.1"
tokio = { version = "1", features = ["full"] }

Example: spawn, wait, and collect results

The orchestration modules expose public functions that mirror the CLI commands. Here's the typical pattern for spawning parallel agents and gathering results:

# From the CLI — the most common way to use these primitives:
sid1=$(zag spawn --name analyzer --tag batch -p claude "analyze auth module")
sid2=$(zag spawn --name reviewer --tag batch -p gemini "review test coverage")

# Wait for all tagged sessions to finish
zag wait --tag batch --timeout 5m

# Collect results into a JSON array
zag collect --tag batch --json > results.json

# Chain results into a synthesis step
zag pipe --tag batch -- "summarize all findings into a report"

Each CLI command delegates to the corresponding module function (e.g., zag spawn calls zag_orch::spawn::run_spawn()). The module functions accept structured arguments and return typed results, so you can call them from Rust code without going through the CLI.

Example: session status polling

sid=$(zag spawn "long running task")

# Poll until complete
while true; do
    status=$(zag status "$sid" --json | jq -r .status)
    case "$status" in
        completed) echo "Done!"; break ;;
        failed)    echo "Failed!"; exit 1 ;;
        *)         sleep 5 ;;
    esac
done

# Get the result
zag output "$sid"

License

MIT

zag-orch 0.8.1