Skip to content

flow

Reusable multi-agent workflows and CodeRabbit-style code audit — making workflows simple.

flow lets you describe a multi-agent workflow in ~15 lines of YAML (three knobs: agents, phases, loops) and run it end-to-end with no human gates. It also ships battle-tested plan/implement/audit skills.

It unifies pair's plan/implement/review simplicity with @quintinshaw/pi-dynamic-workflows' dynamic orchestration and a CodeRabbit-style audit rigor. It coexists with pair and will eventually deprecate team.


The mental model (read this first)

Flow has three layers, kept deliberately separate. Confusing them is the #1 source of confusion, so here is the whole picture:

LayerWhat it isWhere it livesWho writes it
AgentA role's behavior — a system prompt + frontmatter (tools, thinking, …). Never carries a model: — the model is supplied at dispatch.~/.pi/agent/agents/<name>.md (global) or .pi/agents/<name>.md (project overrides global)flow ships 6 defaults; you edit/add freely (write-once)
WorkflowWhat runs, in what order — either a built-in skill (Tier 1) or a YAML file (Tier 2).Tier 1: built-in skills · Tier 2: ~/.pi/sf/flow/workflows/<name>.yaml (global defaults) or .pi/sf/flow/workflows/<name>.yaml (project override)flow ships skills + 4 example YAMLs (/sf-flow-seed); you add YAMLs
ConfigRuntime settings — which model each agent runs on, audit thresholds, worktree.~/.pi/sf/flow/config.json (global) + .pi/sf/flow/config.json (project)you (partial is fine)

⚠️ Config does NOT define agents or workflows

Agents (reviewer, explorer, developer, planner, auditor, synth) are defined as .md files (~/.pi/agent/agents/<name>.md) and used by the plan/implement/audit skills. config.json only sets which model each agent runs on (plus audit / worktree settings). An agent's behavior lives in the .md file — config never describes how an agent thinks.

Concretely: {"reviewer":{"model":"anthropic/sonnet-4-6"}} means "run the reviewer agent (already defined) on Sonnet 4.6" — it does not create the reviewer. The six model groups (reviewer/explorer/developer/planner/auditor/synth) are all optional; an unset model inherits the orchestrator (uniform fallback, no fail-fast).

Where the model comes from, per tier:

  • Tier 1 skills (sf_flow_plan / sf_flow_implement / sf_flow_audit) — models self-resolved by the skill from config.json (project then global → env → inherit orchestrator). The tool pre-resolves + echoes them (visibility only); the skill is the resolver, so a workflow delegating via a skill: phase honors config too.
  • Tier 2 YAML flows — each agent sets its model: inline in the YAML (a fuzzy alias like sonnet or haiku), independent of config.json (falls back to the .md model:, else the orchestrator).

Installation

bash
pi install npm:@pi-stef/flow

Flow's skills are discovered natively via pi.skills. To author flows that pull from Jira/PRDs, also install @pi-stef/atlassian.


Quickstart

bash
# 1. Audit your current diff — zero config, runs the 7-angle triad + dual-blind gate
/sf-flow-audit

# 2. Plan, then implement a feature (reviewer model from config.json)
/sf-flow-plan add OAuth login
/sf-flow-implement 2026-07-20-oauth-login

# 3. Run a reusable flow end-to-end (seed the 4 examples to ~/.pi/sf/flow/workflows via /sf-flow-seed)
sf_flow_auto code-review "review the auth changes"

You can also drive everything in natural language:

"Plan a feature for adding user authentication, use anthropic/sonnet-4-6 as reviewer"
"Implement the plan in ai_plan/2026-07-20-oauth-login"
"Run the code-review flow on the staged diff"

Built-in agents

Six write-once agent definitions ship in packages/flow/agents/ and are copied to your global discovery dir (~/.pi/agent/agents/) by /sf-flow-seed (or lazily on first use of a Tier 1 skill):

AgentRoletoolsthinking
plannerWorkflow Planner — milestones + storiesread, grep, find, lsmedium
explorerCodebase Explorer — read-only researchread, grep, find, lslow
developerTDD Developer — red/green/refactorread, grep, find, ls, write, bashmedium
reviewerPlan/Implementation Reviewerread, grep, find, lshigh
auditorCode Auditor (CodeRabbit-style)read, grep, find, lshigh
synthSynthesis / Report Writerread, writemedium
  • Write-once: flow never overwrites an existing agent file, so you can edit any of them freely.
  • No model: in the file: the model is resolved at dispatch time (Tier 1: from config.json; Tier 2: from the YAML's inline model:).
  • Project overrides global: a <repo>/.pi/agents/reviewer.md shadows the global one (pi-subagents semantics).

Add a new agent: just drop a <name>.md at ~/.pi/agent/agents/ (global) or .pi/agents/ (project), then reference it by name in a workflow's agents: block. sf_flow_create_workflow will also write a write-once stub for any agent you declare that doesn't yet exist.


Built-in workflows (examples)

Four reference flows ship in packages/flow/workflows/. They are global defaults — copy them once with /sf-flow-seed (or they seed lazily on first use) into ~/.pi/sf/flow/workflows/, where they're available in every project:

WorkflowFileWhat it does
code-reviewcode-review.yamlCodeRabbit-style review of a diff (audit triad)
ship-featureship-feature.yamlPlan → implement → audit a feature, gated until APPROVED
auth-auditauth-audit.yamlScan route files, fan out audits, dedup, synthesize a report
research-reportresearch-report.yamlMulti-perspective research with cross-checking + synthesis
  • Global defaults live at ~/.pi/sf/flow/workflows/; a project override at <repo>/.pi/sf/flow/workflows/<name>.yaml shadows the global one (resolved project→global by sf_flow_auto).
  • /<name> commands (/code-review, …) register at pi startup from the global + current-project workflow dirs.
  • Re-seed safely: /sf-flow-seed never clobbers your edits — if a file differs from the bundled default, the new default is written as <name>.new beside it.
bash
# Seed the defaults globally, then run one from any project:
/sf-flow-seed
sf_flow_auto ship-feature "add a rate limiter to the API"

Tier 1 — the built-in skills

Five prose skills (fixed, battle-tested step sequences) plus a worktree helper:

SkillSlashToolPurpose
Plan/sf-flow-plansf_flow_planMulti-milestone plan with parallel research + iterative review
Implement/sf-flow-implementsf_flow_implementOne worktree, TDD per story, audit gate before commit
Audit/sf-flow-auditsf_flow_auditCodeRabbit-style audit (7 angles + dual-blind AND-gate + fix-apply)
Auto/sf-flow-autosf_flow_autoRun any defined flow end-to-end, no human gates
Create Workflow/sf-flow-create-workflowsf_flow_create_workflowWizard: interview → agents/phases/loops YAML → /<name>
Seed/sf-flow-seedsf_flow_seedCopy default agents + example workflows to their global locations
/sf-flow-finalizesf_flow_finalizeRemove a flow worktree dir, preserve its branch

sf_flow_plan

Create a multi-milestone implementation plan with parallel research and iterative reviewer approval. Produces ai_plan/<slug>/.

ParameterRequiredDescription
promptNoThe task to plan
reviewer_modelNoOverride reviewer model (else self-resolved from config)
explorer_modelNoOverride explorer model (inherits parent if unset)

Phases: (1) fan out N explorers in parallel → codebase map; (2) gather requirements one question at a time; (3) design via brainstorming; (4) plan via writing-plans (milestones + S-MN{seq} stories); (5) iterative reviewer loop (fix P0/P1/P2, max 10 rounds); (6) write plan files; (7) optional Telegram notify.

sf_flow_implement

Execute an approved plan in one worktree (flow/<slug>, git-only), TDD per story, with the audit triad as a non-optional gate before commit.

ParameterRequiredDescription
pathYesPlan folder slug or path under ai_plan/
reviewer_modelNoOverride reviewer model

Per-milestone loop: TDD each story → reviewer loop → commit to the worktree branch → update the tracker. After all milestones: run sf_flow_audit on the accumulated diff; on REVISE (any P0/P1/P2) loop back to the failing story (not the whole plan), bounded by audit.max_rounds (default 5). Finish with sf_flow_finalize (removes the worktree dir, preserves the flow/<slug> branch for a PR).

sf_flow_audit

CodeRabbit-style audit returning P0–P3 findings + a verdict (APPROVED / REVISE). See the audit triad below.

ParameterRequiredDescription
targetNoDiff target: a git ref range, a file path, or workdir. Defaults to git diff HEAD (staged + unstaged)
reviewer_modelNoOverride reviewer model
apply_fixesNoIf true, run respond-review to apply must-fix / should-fix

sf_flow_auto

Run a defined flow end-to-end with no human gates.

ParameterRequiredDescription
workflowYesFlow name (resolved project→global: .pi/sf/flow/workflows/<name>.yaml overrides ~/.pi/sf/flow/workflows/<name>.yaml)
inputYesprompt · path to a markdown file · prd:<path> · jira STORY-123

Input forms: prompt (verbatim), md-file (file contents), prd:<path> (parsed PRD), jira STORY-123 (resolved via @pi-stef/atlassian). Phases run sequentially; intra-phase fan-out via parallel(); loops run to a terminal state (success / no-op / blocked / exhausted).

sf_flow_create_workflow

Turn intent into a validated flow. Interviews you one question at a time (skip if you pass all params), writes .pi/sf/flow/workflows/<name>.yaml (project-scoped), emits write-once agent stubs for any new agents, validates with validateFlowYaml, and registers /<name>.

ParameterRequiredDescription
nameNokebab-case flow name
descriptionNoOne-liner
inputNoprompt / md-file / prd / jira
agents_yamlNoPre-formed agents YAML to skip the interview
phases_yamlNoPre-formed phases YAML
loops_yamlNoPre-formed loops YAML

sf_flow_finalize

Remove a flow worktree directory while preserving its branch. Call after sf_flow_implement finishes.

ParameterTypeDescription
worktree_pathstringAbsolute path of the flow worktree to remove

Tier 2 — declarative YAML flows (the 3-knob model)

This is the heart of flow. Describe a workflow with three knobs and the generator compiles it into a pi-dynamic-workflows script.

yaml
# .pi/sf/flow/workflows/auth-audit.yaml
name: auth-audit
description: Audit auth coverage across route files
input: prompt
agents:
  scanner: { tools: [read, grep, find], model: haiku, thinking: low }
  auditor: { tools: [read, grep, find], model: sonnet, thinking: high, isolated: true,
             schema: { verdict: "APPROVED|REVISE" } }
  synth:   { tools: [read, write], model: sonnet }
phases:
  - { id: scan,   agent: scanner,  prompt: "List every route file under src/routes/.", out: files }
  - { id: audit,  agent: auditor,  fanout: files, prompt: "Audit {{item}} for missing auth checks.", out: findings }
  - { id: verify, agent: auditor,  verify: findings, threshold: 0.66, out: confirmed }
  - { id: report, agent: synth,    in: confirmed, prompt: "Write a cited report from these findings." }
loops:
  audit: { until_dry: true, max_rounds: 3, dedup_key: "{{file}}:{{line}}:{{summary}}" }

Run it: sf_flow_auto auth-audit "check the API routes".

Knob 1 — agents

A map of agent-name → definition. Each agent's behavior comes from its .md file (by name); the YAML only adds runtime config:

FieldTypeDescription
toolsstring[]Tools the agent may use (e.g. [read, grep, find])
modelstringFuzzy model alias (haiku, sonnet, opus, …) resolved by pi-dw. Independent of config.json
thinkingenumoff · minimal · low · medium · high · xhigh · max
isolatedbooleanSpawn in a fresh context (no parent conversation)
schemaobjectStructured output contract, e.g. `{ verdict: "APPROVED

Knob 2 — phases

An ordered list. Each phase runs exactly one of agent / skill / raw:

FieldTypeDescription
idstringPhase identifier (referenced by loops)
agentstringRun an agent (must be declared in agents)
skillstringRun a built-in skill (e.g. sf-flow-audit) — opaque to the generator
rawstringRun a raw pi-dw snippet — opaque to the generator
promptstringPrompt template; the fanout item and prior out vars are interpolated (see examples)
fanoutstringIterate a list — a prior phase's out var or an args.* runtime input (agent phases only)
verifystringCross-check a prior out; pass when >= threshold of items survive
thresholdnumberVerify pass ratio (default per flow)
instring | string[]Feed prior out(s) into this phase
outstringName this phase's output (referenced by later phases / fanout / verify)

Knob 3 — loops

A map of phase-id → loop. Two kinds:

FieldApplies toDescription
until_drydiscoveryKeep running the phase until it stops finding new things. Requires fanout. Optional dedup_key (a template over item fields, e.g. file:line) and consecutive_empty (stop after N empty rounds)
untilgateuntil: approved — run until the agent's schema.verdict is APPROVED. Requires the agent to declare a verdict schema
fail_ongateSeverities that block: [P0, P1, P2] (default)
max_roundsbothBound on iterations (default per flow)

Validation rules

validateFlowYaml enforces these cross-field rules so a loop/fanout is never silently swallowed (invalid flows fail at registration, not at runtime):

#Rule
1Each phase sets exactly one of agent / skill / raw
2agent must reference a name declared in agents
3fanout is allowed only on agent phases (skill/raw are opaque)
4fanout requires out (parallel results must be captured)
5verify must reference a prior phase's out
6out names must be unique across phases
7loops.<phaseId> must reference an existing phase
8Loops are not allowed on skill phases
9Loops are not allowed on raw phases
10until_dry requires the phase to set fanout
11until: approved requires the phase agent to declare a schema.verdict

Defining a new flow

Two paths to the same result (a .pi/sf/flow/workflows/<name>.yaml runnable via sf_flow_auto):

  • Wizard — invoke /sf-flow-create-workflow and answer one question at a time. It writes the YAML, emits any missing agent stubs, validates, and registers /<name>.
  • By hand — create .pi/sf/flow/workflows/<name>.yaml (project) or ~/.pi/sf/flow/workflows/<name>.yaml (global) following the schema above. Run sf_flow_create_workflow once to validate + register /<name>, or just run sf_flow_auto <name> <input> directly (it validates + generates eagerly).

Code audit triad

sf_flow_audit runs four modules sharing a P0–P3 + verdict contract. VERDICT: APPROVED only when no P0/P1/P2 remain.

ModuleWhat it does
codereviewWraps pi-dw /code-review: 7 finder angles (A/B/C correctness medium-tier, D/E/F cleanup small-tier, G altitude big-tier). Each finding is verified 3-way (CONFIRMED / PLAUSIBLE / REFUTED — REFUTED dropped), deduped by file:line:summary, ranked correctness > cleanup > altitude. Diffs cap at MAX_DIFF_CHARS (200000).
auditcodeA 10-section self-checklist (Supply Chain & Security, Provenance & Metadata, Law of Demeter, …). gateExitCode returns 1 on any failure; qualityScore = 100*(total − must − should)/total.
requestreviewSanta-method dual-blind AND-gate: two independent reviewers (neither sees the other) must both pass (mustFix == 0 && score >= threshold). Bounded by MAX_REVIEW_ITERATIONS (5); a 6th iteration is forbidden.
respondreviewcategorize (P0/P1 must-fix, P2 should-fix, P3 consider) + applyOrder (severity rank). If apply_fixes, applies in order then re-runs test/typecheck/lint. Hard gate: every finding is addressed (fix, disagree+document, or clarify).

Output is rendered via renderReport in pair's ### P0…P3 + ## Verdict format.

/sf-flow-audit vs the code-review flow

Both run the same audit triad, so they look interchangeable — but the wrapper matters:

/sf-flow-auditsf_flow_auto code-review
Tier1 (built-in skill)2 (YAML flow)
What runsthe skill inline, in your current sessiona generated pi-dw script that spawns a general-purpose agent to run the skill
Model sourceconfig (reviewer.model)config (reviewer.model) — via the skill
Resultfindings + verdict into your chata flow result — the skill phase's out is opaque (a placeholder string)
Gated loopno (one-shot; apply_fixes applies once)not on a skill phase (skill phases can't loop)
Extensiblefixed skill stepsedit the YAML: add phases, chain it, version & share it
Inputtarget (git ref / file / workdir)prompt · md-file · prd · jira

Today code-review.yaml is a pure skill wrapper (no agent phases of its own), so functionally it's nearly identical to the skill — including the model source: both resolve the reviewer from config. Use the skill for a quick, zero-overhead audit in your current task. Use the flow when you want a reusable, shareable, composable artifact — e.g. chain it after plan + implement (that's ship-feature.yaml). Remember: a flow's agent phases get their model from the YAML (agents.<name>.model); its skill phases inherit the skill's config-driven model.

Need a gated audit loop in a flow? A skill phase can't loop (rule #8). Use an agent phase with until: approved instead — see the audit phase in ship-feature.yaml, which gates an auditor until verdict: APPROVED.


Agent resolution

When a skill or phase needs to spawn an agent, the type is resolved deterministically:

  1. If an agent definition <name>.md exists → spawn that named agent (name).
  2. Else planner → built-in Plan; reviewer → built-in Reviewer.
  3. Anything else with no .mdgeneral-purpose.

A missing explorer.md does not fall back to the built-in Explore (which forces Haiku) — it yields general-purpose, inheriting the orchestrator model. This rule is encoded in code (resolveAgentType) + stated verbatim in every tier-1 skill, so the direct (tool) path and the workflow (skill: phase) path spawn the same agent type.

The orchestrator is orchestrator-only: in /sf-flow-implement it writes no code — it delegates each milestone to the developer agent and runs the per-milestone reviewer gate.

Plan standard (exhaustive milestone plans)

Plans are consumed by an implementer that may be a weaker model, so /sf-flow-plan enforces an exhaustive standard: every story must specify exact files + lines, a precise change (no vague verbs like "refactor"/"improve"), rationale, acceptance criteria, edge cases, test expectations, and dependencies — enough that a less-intelligent model can implement it with zero remaining design decisions. A completeness self-check runs before finalizing, and the reviewer gate REVISEs under-detailed stories independent of correctness. (This applies to both the plan tool and a workflow's plan phase — both execute the same skill.)


Configuration

Config is layered: project .pi/sf/flow/config.json is merged over global ~/.pi/sf/flow/config.json, both over defaults. Partial configs are fine — anything you omit falls back to its default.

json
{
  "reviewer": { "model": "anthropic/sonnet-4-6" },
  "explorer": { "model": "anthropic/haiku-4-5" },
  "developer": { "model": "anthropic/sonnet-4-6" },
  "planner": { "model": "anthropic/sonnet-4-6" },
  "auditor": { "model": "anthropic/sonnet-4-6" },
  "synth": { "model": "anthropic/haiku-4-5" },
  "audit": { "threshold": 0.94, "max_rounds": 5 },
  "worktree": { "branch_prefix": "flow/" }
}
KeyTypeDefaultDescription
<role>.modelstringModel for one of the six agents: reviewer, explorer, developer, planner, auditor, synth. All optional; unset ⇒ inherits the orchestrator (no fail-fast)
audit.thresholdnumber0.94Dual-blind AND-gate pass score
audit.max_roundsinteger5Max audit fix-loop iterations
worktree.branch_prefixstringflow/Branch prefix for implement worktrees

Environment variables: SF_FLOW_REVIEWER_MODEL, SF_FLOW_EXPLORER_MODEL, SF_FLOW_DEVELOPER_MODEL, SF_FLOW_PLANNER_MODEL, SF_FLOW_AUDITOR_MODEL, SF_FLOW_SYNTH_MODEL.

Model resolution chain (Tier 1 skills)

Tier-1 skills self-resolve each agent's model:

  1. A model passed in the invocation context (tool echo / workflow hint) — wins.
  2. Config file — <role>.model (project, then global).
  3. Environment — SF_FLOW_<ROLE>_MODEL.
  4. Inherit the orchestrator model (uniform fallback, no fail-fast). At dispatch, an unset model is omitted so pi-subagents applies the agent .md model: (if any) or inherits the orchestrator.

Note: Tier 2 YAML agents ignore this chain — they use the inline model: field in the YAML (else the .md, else the orchestrator).

Model precedence

A common question: if an agent .md sets a model: and config sets a different one, which wins? Config is a 6-agent model registry (reviewer/explorer/developer/planner/auditor/synth); each group is additionalProperties: false.

Agent used by.md model:YAML model:config→ Model used
Tier 1 skill(applied by pi-subagents only if config/env unset)setconfig
Tier 1 skill(applied if unset)unset.md → else orchestrator (uniform fallback)
Tier 2 flow agentsetset(no effect)YAML
Tier 2 flow agentsetomitted(no effect).md (fallback)
Tier 2 flow agentomittedomitted(no effect)orchestrator / session model

Why config wins for Tier 1 (when set): the skill self-resolves + passes the model explicitly at dispatch — Agent({ subagent_type: "reviewer", model: "<from config>" }) — overriding the .md. If config/env are both unset, the model is omitted so pi-subagents falls back to the .md model: (if any), else the orchestrator. The six default agents ship with no model: — so an unset config simply inherits the orchestrator (no error).

Why YAML wins for Tier 2: the generator emits model: into the agent call only when the YAML declares it (generate.ts: if (def.model) parts.push(...)). Omit it and pi-subagents falls back to the .md's model: (else the orchestrator). Config has no effect on Tier 2 agents.


Architecture

Skill-driven design

The tools are thin: each pre-resolves config + ensures agents exist, then hands off to a SKILL.md containing the actual step sequence. The extension provides only config loading, model resolution, write-once agent templates, agent-type resolution, and worktree helpers.

Model resolution

Tier-1 skills self-resolve models from config.json (project → global → env → inherit orchestrator); the tools pre-resolve + echo them for visibility. Agent types resolve by .md filename match (see Agent resolution).

Orchestrator-only implement

/sf-flow-implement writes no code: it delegates each milestone to the developer agent (TDD), runs the per-milestone reviewer gate, then the audit gate. The orchestrator only reads, spawns, parses, and aggregates.

Worktree lifecycle (implement)

  1. Create one git worktree with branch flow/<slug> (git-only; non-git targets skip it).
  2. Per milestone: delegate to the developer agent (TDD) → reviewer loop → commit to the worktree branch → update the tracker.
  3. Audit gate on the accumulated diff; on REVISE, loop back to the failing story (bounded by audit.max_rounds).
  4. sf_flow_finalize removes the worktree directory while preserving the flow/<slug> branch for a PR.

Plan-folder layout

ai_plan/YYYY-MM-DD-<slug>/
├── original-plan.md         # Raw approved plan
├── final-transcript.md      # Conversation log
├── milestone-plan.md        # Full specification
├── story-tracker.md         # Status tracking
└── continuation-runbook.md  # Resume context

ai_plan/ is gitignored.


Migration from team

flow replaces team's dynamic dispatch + audit on the pi-subagents / pi-dynamic-workflows foundation — without subprocess orchestration or milestone/story parallel lanes (deliberately dropped).

teamflow
plan / implementsf_flow_plan / sf_flow_implement
auditsf_flow_audit
user-defined workflowsTier 2 YAML flows via sf_flow_create_workflow + sf_flow_auto
subprocess orchestrationdropped (pi-subagents instead)
parallel lanesdropped

flow is self-contained — it imports neither @pi-stef/team nor @pi-stef/agent-workflows — so deprecating team later cannot break it.


Key differences from pair

Featurepairflow
Plan researchSingle explorerFleet of parallel explorers
Implement gateReviewer loopReviewer loop + audit triad
Custom workflowsTier 2 YAML (agents/phases/loops)
Code auditCodeRabbit-style triad (sf_flow_audit)
Foundationpi-subagentspi-subagents + pi-dynamic-workflows