Skip to main content
Glama

subtask

A local delegation scheduler for coding agents. One MCP server (and a twin CLI) lets Claude Code, Codex, Kimi Code or OpenCode start work in parallel, wait for it with a single call, and read back a short summary with evidence. It picks an engine that can take the job, books money and slots safely across processes, and says honestly how isolated each run is.

start_many([{task: "Fix the flaky test in tests/test_sync.py", repo: "/src/app", verify: "pytest -q tests/test_sync.py"},
            {task: "List every caller of parse_date()", kind: "read", readonly: true, cwd: "/src/app"}])
  -> st-4f2a91 started · sonnet-api · branch subtask/st-4f2a91 · sandbox
     st-77c0de started · haiku-api · /src/app · readonly
wait(["st-4f2a91", "st-77c0de"])          # Claude Code shows: Subtask · 01:16 · 1/2 ended — st-4f2a91 running tests: pytest -q
  -> st-4f2a91 done · sonnet-api · 6m · 0.412$ · verified · ...
     ## Summary (≤10 lines: the answer, files, commits, tests, what is left)
result("st-4f2a91", evidence=True)        # JSON: base/head, changed files, observed commands, verify exit code, cost

Why

  • Save the caller's context. The worker's search, test runs and dead ends stay in its own session; the caller reads about ten lines.

  • Few round trips. start_many + one wait replace a polling loop.

  • Use whatever has room. engine="auto" filters engines that can enforce the requested isolation, are installed, fit the budget and have quota, then ranks them with an explicit utility (subtask routing explain).

  • Money is a primitive. Paid engines reserve their budget before any work, under one lock with the slot; every reservation is closed exactly once.

  • Evidence, not claims. verify="..." runs your check on the commit the worker left; result(evidence=True) separates what subtask observed from what the worker reported.

Related MCP server: vanth

Install

The distribution is subtask-mcp (the PyPI name subtask is an unrelated project). Full guide, per client, with native commands: docs/install.md.

uv tool install "git+https://github.com/tedin7/subtask@main"   # or: uv tool install /path/to/checkout
subtask install --client all          # prints the plan for every detected client
subtask install --client all --yes    # applies it: MCP server + skill
subtask doctor --client all           # checks app, config entry and a real handshake

subtask --version reports the installed Git commit when the installer records it. For local, editable, or registry installations without Git provenance it reports commit unknown.

Jev provides advisory workflow checks automatically, or only when requested:

subtask jev                 # policy, key availability and the current process's budget limits
subtask jev setup           # guided setup; key input is hidden
subtask jev auto            # automatic routing, feedback and final delivery advice
subtask jev manual          # explicit review submissions only
subtask jev off             # block new Jev submissions

New installations start in manual mode. The policy and private key are shared by the configured clients. Enter keys through hidden subtask jev setup input or explicit stdin, never chat, argv or tool arguments. In auto, start_many appends routing advice, reply includes feedback advice, and final wait / result include evidence consistency and risk triage. Read this advice together with the existing baseline output. Routing and feedback preserve authorized work and worker instructions. manual requires explicit submissions; off blocks new ones.

These extra checks share the existing cap and deduplicate identical content. skipped, blocked and unknown are not passes; never retry an unknown send. Distinguish raw provider_choice from filtered assessment: a failed verification can veto supported deterministically, without being a Jev finding. Suggested next actions grant no authority, replace no checks, and trigger no automatic model fallback, merge, retry or release. See Jev setup and limits and the workflow study and its limits. These instructions describe the upcoming release; they do not certify a live install.

Claude Code plugin: claude plugin marketplace add tedin7/subtask then claude plugin install subtask@subtask. Codex: codex plugin marketplace add tedin7/subtask. API engines read ANTHROPIC_API_KEY from ~/.config/subtask/env (chmod 600).

Engines

engine

pays with

read-only

isolation it can enforce

haiku-api, sonnet-api, opus-api

API key, monthly cap

yes

sandbox (Claude Code OS sandbox)

codex

Codex login (quota from local session files)

yes

sandbox (workspace-write), isolated

opencode-go

opencode-go subscription

no

worktree, isolated

kimi

Kimi login

no

worktree, isolated

dsh

DeepSeek key, same cap (subtask-mcp[dsh])

no

worktree

opencode

OpenCode default provider (manual only)

no

worktree, isolated

Add an engine without touching the core: an EngineAdapter registered under the subtask.engines entry point (see CONTRIBUTING.md).

Isolation, honestly

  • worktree (default): a git worktree and branch per writing job. It prevents collisions; it is not a host sandbox.

  • sandbox: the engine's own sandbox. Same user: a guard rail.

  • isolated: bubblewrap. Read-only system, writable worktree and git dir only, a private HOME with only the engine's own state. Needs bwrap.

  • untrusted: sandbox or stronger, and no network for the worker's commands.

A job that cannot get the policy it asked for is refused, never downgraded. Output is redacted for common secret formats before it is saved or shown; redaction is a second layer, not a guarantee. See SECURITY.md.

Tools (MCP) and CLI

tool

what it does

start(task, kind, repo, cwd, files, readonly, engine, max_usd, effort, base, max_turns, policy, verify, isolation, max_retries, adversarial, context_refs, auto_repomap, tier, invariants, allowed_paths, symbol_scope, oracle_cmd)

start one job (see below)

start_many(tasks)

start several; partial success is listed per item. Items with id and depends_on form a group (grp-…) run as a DAG without extra turns; foreach=<parent id> makes one copy per item of the parent's .subtask/fanout.json (at most 8), and dependents wait for every copy; after="any" starts when one parent succeeded

integrate(ids, action="apply", auto_resolve=False)

worktree jobs back: diff, apply (all or nothing, uncommitted), discard; auto_resolve starts a reconciliation job on conflict

consensus(prompt, engines, verify_cmd, isolation="worktree")

2 to 4 engines solve it blind in their own worktrees, then one job compares their diffs as anonymous patches and writes one solution, checked by verify_cmd and the invariants; returns a group id

bisect(good_ref, bad_ref, test_cmd, parallelism=4, auto_fix=False)

first commit that makes test_cmd fail, testing up to parallelism (max 8) commits per round in temporary worktrees; returns the commit, author and diff; auto_fix starts a verified fix job

map_reduce(glob_pattern, prompt_template, batch_size=5, concurrency=3, verify_cmd, isolation="worktree")

one job per batch of files ({{files}} in the template), at most concurrency at a time; returns a group id

wait(ids, timeout=300, mode="all", since=None, stall_timeout=None)

block until they end (any: the first; first_success: the first done and verified, the others are stopped); returns early on a stalled job; progress notifications while waiting; since cursor for clients without progress

steer(id, action, instruction=None)

hint (queued, sent as a reply when the attempt ends), abort, retry (fresh job with the instruction)

inspect(id, tail=80, grep=None)

raw log lines, only when the summary is not enough

status(id) / result(id, full, evidence)

one line / summary or full text or JSON envelope

reply(id, message) / stop(id) / cleanup(id)

continue / stop the work / remove a clean worktree (branch kept)

engines()

capacity per engine with source, freshness and confidence, plus spend

Options of start:

  • isolation="worktree": own worktree and branch (like repo=), plus SUBTASK_PORT (from 18100), SUBTASK_ID and a private TMPDIR. The result lists files_modified and diff_stat. This also applies to readonly=True; repo= alone keeps read-only jobs in the original directory. The CLI exposes the same choice through start --isolation worktree.

  • verify + max_retries: a failed check resumes the job with the output; when every retry fails, a worktree goes back to its best attempt (scored from "N passed / N failed").

  • adversarial=True: a Breaker job writes edge-case tests from the spec only; they are copied into the Builder's worktree and run with verify.

  • context_refs: file:PATH[:A-B], git:diff[:REF], subtask:ID:summary|diff, resolved before start. auto_repomap=True adds tracked files with their top-level symbols (cached per HEAD).

  • invariants (default ["no_test_deletion", "no_suppression"], [] turns them off): before verify counts, test functions may not decrease, no new skip/xfail markers, no new # type: ignore, # noqa or # pragma: no cover. A violation is a failed check with the reason, so a retry sees it.

  • allowed_paths: files changed outside these paths are put back and the revert is committed.

  • symbol_scope=["path.py::name", ...]: only those top-level functions or classes may change in those files. integrate then merges several jobs' edits to one Python file symbol by symbol; overlaps, import or constant changes, and symbols changed on the target meanwhile are a conflict, never a guess.

  • oracle_cmd: after a passing verify, runs the command on the job's base and on its result at the same time and reports whether exit code and stdout match, plus duration_ms_before, duration_ms_after, speedup_pct.

  • tier: fast (effort low), deep (effort high, kind hard), free_only. Past 75% of the monthly cap, auto and balanced route automatically selected engines to free engines and the reply carries budget_warning. For these tiers, an explicitly selected paid engine remains allowed with a warning. fast and deep do not change or emit this warning at this threshold. Explicit free_only still rejects paid engines. The monthly cap remains subject to the separate budget admission check.

  • Kimi's default K3-256k and supported managed model aliases accept low, high and max effort. Subtask maps medium to high and xhigh to max for those models, which can consume more quota. New sessions retain the effective effort when resumed; custom model aliases keep the requested value.

Memory: when a check fails and a retry fixes it, subtask stores a short lesson for that repository in $SUBTASK_HOME/engrams/ (at most 50, least recently used dropped). Jobs on the same paths get the top three. Groups have a blackboard file for shared notes; new notes show in wait(since=...).

CLI only: subtask board [--json] (the view the OpenCode plugin renders), subtask doctor, gc [--apply], du, roi, routing explain|calibrate, watch ID..., install, uninstall, and --model, --no-sandbox, --untrusted on start.

The gc preview reads recorded job states without settling workers; jobs recorded as active are kept. gc does not calculate file sizes, so its output reports folder counts rather than reclaimed bytes. Run subtask du separately for disk usage; scanning large stores can take time. A copy with files in .reports is kept until a collector leaves a receipt, the regular file .reports/.collected (any content; its mtime must be at least that of the newest report). Empty .reports needs no receipt.

Progress in the chat

client

during a wait

Claude Code 2.1 (TUI)

live line under the tool call, verified

OpenCode 2.0

notifications received, not shown: use wait(since=...)

Kimi Code 2.1

client does not request progress: wait(since=...)

Codex 0.162

not yet verified (account at its usage limit)

Details and evidence: docs/progress-matrix.md.

Settings

variable

default

SUBTASK_HOME

~/.local/share/subtask (jobs, worktrees, ledger, telemetry)

SUBTASK_ENV_FILE

~/.config/subtask/env

SUBTASK_MONTHLY_CAP_USD / SUBTASK_DEFAULT_MAX_USD / SUBTASK_MAX_JOB_USD

180 / 2 / 20

SUBTASK_MAX_RUNNING

4 (global across all processes)

SUBTASK_ROUTING

~/.config/subtask/routing.json (weights, "mode": "legacy")

SUBTASK_JOB_RETENTION_DAYS / SUBTASK_TELEMETRY_DAYS

30 / 90

SUBTASK_PROGRESS_MIN_S / SUBTASK_PROGRESS_HEARTBEAT_S

2 / 10

SUBTASK_CODEX_JOB_HOME

~/.codex-job, used if it has config.toml; otherwise a sanitized ~/.codex-jobs is prepared

SUBTASK_CODEX_KEEP_MCP

unset; set to keep the normal Codex home and its MCP servers

Costs of API engines come from the SDK's estimate; a run whose real cost is unknown is charged its whole reservation. Telemetry stays on this machine. An existing job home is used as-is: its configuration and shared authentication are managed by the operator. An explicit CODEX_HOME takes precedence. For isolated jobs, the chosen home must be an absolute directory narrower than HOME.

Platforms

Linux: supported. macOS: degraded (no /proc start times for liveness, no bwrap: isolated refused). Windows: not supported (fcntl).

Documentation

Architecture · Requirements matrix · Benefits and measurements · Benchmark protocol · Install · Releasing · Contributing

License

MIT

Available Tools

18 tools
bisectC

First commit in good_ref..bad_ref that fails test_cmd, testing up to parallelism commits at once. auto_fix: start a fix job.

Inputs: bad_ref (required), good_ref (required), test_cmd (required), repo, +2 more.

cleanupB

Remove a job's worktree, keep branch.

Inputs: id (required).

consensusB

2-4 engines solve prompt blind in worktrees, then one job merges the best (verify, invariants). Returns a group id for wait().

Inputs: prompt (required), engines (required), repo, max_usd, +2 more.

enginesC

Free quota and API spend.

Inputs: no named parameters.

inspectA

Raw log lines of a job (last tail, filtered by grep). Only when the summary is not enough.

Inputs: id (required), grep, tail.

integrateA

Bring worktree jobs back. diff first to review; apply = uncommitted, all or nothing, Python files of symbol_scope jobs merged by symbol; discard removes worktree and branch. auto_resolve: a reconcile job on conflict.

Inputs: ids (required), action, auto_resolve.

jevA

Show or change the shared Jev policy: status | auto | manual | off. Only the operator changes the policy: do not switch it to obtain or avoid a check. Auto checks every new final delivery once within the existing budget; read that outcome in wait()/result before any manual review. All advice is consultative. Credentials are never accepted here: add or replace a key in a terminal with subtask jev setup (hidden input), never in chat, argv or a tool argument. Changes apply to new submissions in every configured CLI; no server reload is needed.

Inputs: action.

map_reduceB

The same edit over many files: one job per batch of files matching glob ({{files}} in prompt_template), at most concurrency at once, each in a worktree with verify_cmd. Returns a group id for wait().

Inputs: glob_pattern (required), prompt_template (required), cwd, repo, +5 more.

planA

Preview tasks before workers start. Read deterministic facts and advisory Jev contradictions, then launch=True with plan_id to start the unchanged plan once. Changed inputs require a new preview. This is a coordinator decision within the authorized task, not a new operator permission. Legacy start/start_many remain available. Read dependencies must be explicit in depends_on.

Inputs: tasks, launch, plan_id.

replyC

Jev auto adds advisory feedback checks; read the output. Continue a finished job.

Inputs: id (required), message (required).

resultD

Job summary; full=True for all; evidence=True for the JSON envelope.

Inputs: id (required), full, evidence.

reviewA

Advisory Jev review of a terminal delivery against the parent's criteria (1-12). Read the automatic outcome in wait()/result first; do not resubmit the same delivery. Default prepares a local evidence packet without network; packets=True prepares separate claim packets and manifests offline (never submits). submit=True sends one request (unknown sends are never retried). Supply original_request from the coordinator to judge full scope; without it scope_assessment is unproven, which is neither a pass nor a contradiction. supported is advice, not acceptance. provider_choice is the raw answer; assessment includes local vetoes (missing, failed or mismatched evidence), which are not findings by the model. Jev never accepts, merges, deploys or retries the worker; local checks remain necessary. Key/budget errors are final for the call: keys only from subtask jev setup, never a tool argument.

Inputs: id (required), criteria (required), submit, packets, +1 more.

startA

Start one job; returns its id. kind: read|code|review|hard. Writes: repo= or isolation='worktree' (own branch). model: engine-specific model id (opencode, codex, kimi, API engines); omitted = the engine's default. verify: shell check run by subtask after the job; max_retries (0-5) resumes with the failure. invariants: default ['no_test_deletion','no_suppression'] fail verify on deleted/skipped tests or new noqa; [] = off. allowed_paths: files outside are reverted. symbol_scope: ['f.py::func'] only those defs may change; integrate merges by symbol. oracle_cmd: after verify passes, run on base and result; reports output_match and speedup_pct. adversarial: a Breaker job writes the tests first. context_refs: file:P[:A-B] | git:diff[:REF] | subtask:ID:summary|diff instead of pasting text; auto_repomap adds a symbol map. policy: worktree|sandbox|isolated|untrusted. tier: auto|fast|balanced|deep|free_only.

Inputs: task (required), cwd, base, kind, +21 more.

start_manyA

Start several jobs in one call. Items take start()'s arguments. With id + depends_on they form a group (grp-…) run as a DAG; subtask::summary in task/context_refs is replaced by the real job id. With Jev auto, the response includes advisory dependency checks; read them without treating them as permission. foreach=: one copy per item of the JSON list the parent writes to .subtask/fanout.json ({{item}} in task), max 8; dependents wait for every copy. after='any': start when one parent succeeded.

Inputs: tasks (required).

statusD

One line per job.

Inputs: id.

steerB

Correct a job: hint (instruction sent when the attempt ends) | abort | retry (fresh job with the instruction).

Inputs: id (required), action (required), instruction.

stopC

Stop a job.

Inputs: id (required).

waitA

Block until jobs or groups end and return their summaries. mode: all | any (first to end) | first_success (first done and verified; the rest are stopped). Returns early on a stalled job. since: cursor for clients without progress; with it, timeout is capped at 60 s. For Codex: wait(ids, mode='any', timeout=60, since=''), drop ended ids and pass back cursor=. An idle Codex 0.164.0 is not woken by ordinary local MCP progress or log notifications. Includes the automatic Jev delivery/evidence/risk advice, raw provider choice, wrapper assessment and next action: read it before a manual review and do not resubmit the same work.

Inputs: ids (required), any, mode, since, +2 more.

Tool Schema Changelog

Recent tool additions, removals, and schema changes observed during successful MCP inspections.

Loading tool schema changelog…

    TDQS

    C2.8/5.0

    Scored across 18 tools

    Disambiguation3/5

    Most tools target distinct workflow stages, but several boundaries blur: plan versus start/start_many, status versus result/wait/inspect, cleanup versus integrate discard, and general start_many versus specialized consensus/map_reduce. The detailed descriptions help, but an agent could still misselect among orchestration and monitoring tools.

    Naming Consistency3/5

    All names are lowercase snake_case, which is readable, but the convention mixes bare verbs (start, wait, stop, steer) with nouns (status, result, jev, consensus, engines) and does not follow a predictable verb_noun pattern. Two snake_case compound names exist, but semantic naming is inconsistent.

    Tool Count4/5

    Eighteen tools is slightly above the typical well-scoped range, but the server supports a complex orchestration domain with jobs, worktrees, reviews, and specialized workflows. The count is reasonable and most tools appear to earn their place.

    Completeness4/5

    The surface covers job creation, monitoring, steering, stopping, cleanup, integration, review, policy, bisect, consensus, map_reduce, and quota. Minor gaps exist, such as unclear explicit job deletion or group cancellation semantics, but core lifecycle workflows are represented.

    Maintenance

    ActivityMaintained
    ResponsivenessNo recent community issues

    Related MCP Connectors

    Related MCP Servers

    • A
      license
      Not graded
      quality
      B
      maintenance
      Enables AI agents to launch, monitor, and manage background shell jobs with durable event tracking, live progress dashboards, and wake-on-attention for interactive sessions.
      1
      Apache 2.0
    • A
      license
      A
      quality
      C
      maintenance
      Enables an orchestrator like Claude Code to hand coding work off to Cursor SDK agents, run as detached background jobs that survive the session and can be listed, inspected, steered, resumed, or stopped. Agents are asynchronous and reusable across follow-up turns, letting expensive frontier models delegate cheaply without blocking or paying to read the results.
      7
      MIT