version: "1.0.0" name: sweep description: Fan out over the scoped document set via the saved sweep workflow. Workers full-read their shard and write findings + citations directly via cli.ts. Recall over precision — never skip a scoped doc.

Sweep

Scope already happened. Every scoped document gets full-read; workers never skip, never block, never guess. Cost is not a concern; wall-clock is — fan wide.

Shard

bun <CLI> sql "SELECT sd.doc_id, v.uri, v.family, length(v.content) AS chars
               FROM scope_documents sd
               JOIN v_corpus_documents v ON v.id=sd.doc_id
                AND v.corpus=(SELECT corpus FROM runs WHERE run_id='<RUN_ID>')
               WHERE sd.scope_id=<s> ORDER BY sd.rank"

Target ~16 shards (the Workflow concurrency cap) or one per document if fewer — coarser leaves slots idle, finer just adds overhead. Keep families together (a worker reading a base contract should also read its amendments). Long documents (>~150k chars): mark one shard hunter:true (greps for the brief's terms; doesn't read linearly).

Launch

Call the saved workflow by path — do not author a script inline. Everything run-specific goes in args (a JSON object value, not a string):

Workflow({
  scriptPath: "<ROOT>/workflows/sweep.js",
  args: {
    cli:      "<CLI>",
    run_id:   "<RUN_ID>",
    brief:    <brief_id>,
    round:    <round>,
    scope_id: <scope_id>,
    rubric:   "<the brief's rubric, verbatim>",
    rules:    "<content of <ROOT>/workflows/reader.md — Read it verbatim>",
    shards:   [{label:"s00", doc_ids:[1,2,3]}, {label:"s01", doc_ids:[4,5], hunter:true}, …]
  }
})

The script handles the reader prompt, schema, and rescue pass. If you need to deviate (different rules, custom rescue logic), Read <ROOT>/workflows/sweep.js, edit a copy, and pass that as script instead — but default to the saved one.

After

Workers wrote directly; nothing to merge. Reconcile coverage:

bun <CLI> sql "SELECT * FROM v_coverage_gaps WHERE run_id='<RUN_ID>'"

Everything's a gap → the workflow died at launch; re-call it. Partial gaps → some workers crashed; launch a small targeted Workflow for those doc_ids. No gaps → proceed to queue-triage.