aptive-airflow-agent-team

Pi package for a sequential Apache Airflow agent pipeline:

airflow-researcher ──▶ airflow-architect ──▶ airflow-planner ──▶ airflow-implementer ──▶ airflow-reviewer

The extension registers the --airflow-chain flag, /airflow-chain commands, a status widget, and the run_airflow_chain tool.

Install

pi install npm:aptive-airflow-agent-team

Or run for one session without installing:

pi -e npm:aptive-airflow-agent-team --airflow-chain

After installing, launch Pi with:

pi --airflow-chain

What's included

• airflow-chain.ts — extension entrypoint and chain runner.
• themeMap.ts — optional theme compatibility helper.
• agents/agent-chain.yaml — bundled airflow chain definition.
• agents/airflow-*.md — bundled researcher, architect, planner, implementer, and reviewer definitions.
• fixtures/fake-pi-child.mjs — deterministic fake child Pi for local no-provider smoke tests.

Project-local .pi/agents definitions take precedence when present; the bundled definitions are the fallback that makes the npm package self-contained.

Current behavior

• The researcher runs before the architect so architecture follows concrete repo evidence.
• The widget shows a full-width Current Agent activity panel above the chain cards.
• Debug logging can capture step prompts, handoffs, child events, tool calls, token counts, lags, and implementer delta metadata.
• The reviewer receives a programmatic implementer delta and should not fail solely on unrelated pre-existing dirty files.
• If the reviewer returns CHAIN_RETRY_REQUIRED, the orchestrator automatically reruns the implementer once, then reruns the reviewer.

See airflow-chain.README.md for local development and debugging details.

Safety defaults

The chain defaults to read-only repository inspection, safe local validation, and dry-run behavior. It reviews for Airflow parser/heartbeat safety, Snowflake -c claude usage, Aspyn local-doc constraints, XCom size, deployment impact, EKS risk, secrets, and operational risk.

Environment variables

| Variable | Default | Purpose | | ------------------------------------------- | ----------------- | --------------------------------------------------- | | AIRFLOW_CHAIN_PROGRESS_INTERVAL_MS | 15000 | User-visible progress throttle. | | AIRFLOW_CHAIN_IDLE_TIMEOUT_MS | 900000 | Child idle timeout. | | AIRFLOW_CHAIN_STEP_TIMEOUT_MS | 2700000 | Per-step max runtime. | | AIRFLOW_CHAIN_DEBUG / ..._VERBOSE | off | Enable JSONL debug logs. | | AIRFLOW_CHAIN_DEBUG_MAX_CHARS | 20000 | Max characters stored for any single logged string. | | AIRFLOW_CHAIN_DEBUG_HEARTBEAT_INTERVAL_MS | progress interval | Frequency for idle/lag heartbeat records. | | AIRFLOW_CHAIN_DEBUG_RAW_CHILD_EVENTS | off | Log raw child event type records. | | AIRFLOW_CHAIN_DEBUG_STREAM_DELTAS | off | Log every streamed assistant text delta. |