supercode-interchange 0.5.51

Canonical, provider-neutral session interchange primitives for Volter Harness
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
# Hermes's kanban dispatcher as data (hermes_cli/kanban_db.py, read as the reference): the workflow a home runs
# when it declares none. Each transition names the Hermes function it transcribes. Beyond Hermes, and marked
# "ours": pane sessions (session slots, loss and resume), the idle heartbeat and goal nudges, triage by a session,
# machine capacity. A home's config.yaml `kanban:` keys override `params` by name.
#
# Conditions and quantities (guard, validate, roles, limits, order, max) are expressions; targets and action
# arguments are templates, literal text with `{{expr}}` parts, one whole `{{expr}}` giving the expression's value.
description: Hermes Kanban's lifecycle and dispatcher, with supercode's session lanes

params:
  dispatch_in_gateway: true          # kanban.dispatch_in_gateway
  dispatch_interval_seconds: 60      # kanban.dispatch_interval_seconds
  dispatch_stale_timeout_seconds: null
  failure_limit: 2                   # kanban.failure_limit (a card's max_retries wins)
  claim_ttl_seconds: 900             # kanban.claim_ttl_seconds (HERMES_KANBAN_CLAIM_TTL_SECONDS)
  max_in_progress: null              # unset: host.max_in_progress (one per 512 MiB, 2..8)
  max_in_progress_per_profile: null
  max_spawn: null
  default_assignee: null
  review_dispatch: true              # kanban.review_dispatch
  review_skills: [sdlc-review]       # claim_review_task force-loads it
  auto_decompose: true
  auto_decompose_per_tick: 3
  block_recurrence_limit: 2          # the same block kind this many times in a row routes to triage
  rate_limit_cooldown_seconds: 300   # HERMES_KANBAN_RATE_LIMIT_COOLDOWN_SECONDS
  recent_success_seconds: 3600       # the respawn guard's fresh-completion window
  active_pr_seconds: 86400           # the respawn guard's open-pull-request window
  blocker_pattern: '(?i)\b(quota|rate[\s_-]?limit|429|403|auth\w*|unauthorized|forbidden|billing|subscription|access[\s_]denied|permission[\s_]denied|invalid[\s_]api[\s_]key)\b'
  pr_pattern: '(?i)https?://github\.com/[^/\s]+/[^/\s]+/pull/\d+'
  session_grace_seconds: 120         # ours
  goal_mode_default: false           # ours
  goal_max_turns: 20                 # ours
  machine_offline_grace_seconds: 3600   # ours
  machines: {}                       # ours: <machine>: {capacity: n}

roles:
  implementer: card.assignee ?? params.default_assignee
  reviewer: card.assignee ?? params.default_assignee
  creator: card.created_by

initial:
  - guard: "event.initial_status == 'blocked'"
    target: blocked
  - guard: event.triage
    target: triage
  - guard: "!card.parents.all(p, p.status in ['done', 'archived'])"
    target: todo
  - target: ready

on:
  # edits that keep the card where it is; each records Hermes's own event kind
  comment: [{ actions: [{ record: commented }] }]
  assign:
    - validate: [{ expr: "!(card.status in ['running', 'reviewing'])", message: "the card is running; reclaim it before reassigning" }]
      guard: "event.assignee != card.assignee"
      actions: [{ assign: { field: assignee, value: "{{event.assignee}}" } }, { reset: [failures] }, { assign: { field: last_failure_error, value: "{{null}}" } }, { record: assigned }]
    - actions: [{ record: assigned }]
  set_model: [{ actions: [{ assign: { field: model_override, value: "{{event.model}}" } }, { assign: { field: provider_override, value: "{{event.provider}}" } }, { record: model_override_set }] }]
  set_goal: [{ actions: [{ assign: { field: goal_mode, value: "{{event.goal}}" } }, { assign: { field: goal_max_turns, value: "{{event.max_turns}}" } }, { record: goal_set }] }]
  link: [{ actions: [{ link: "{{event.parent}}" }, { record: linked }] }]
  unlink: [{ actions: [{ unlink: "{{event.parent}}" }, { record: unlinked }] }]
  archive:
    - target: archived
      actions: [{ end_run: { outcome: reclaimed, summary: task archived with run still active } }, { record: archived }]
  adopt:   # ours: a live session the board did not start is put on the card as its implementer
    - by: [manager]
      validate: [{ expr: "card.status in ['todo', 'ready', 'blocked', 'scheduled', 'triage', 'review']", message: "only an open card takes a session" }]
      target: running
      actions: [{ claim: implementer }]

statuses:
  triage:
    stored_as: triage
    description: a rough idea waiting to be specified (Hermes asks its auxiliary model; here a session writes it)
    on:
      specify:
        - target: todo
          actions: [{ specify: "{{event}}" }, { record: specified }]
      decompose:
        - target: todo
          actions: [{ decompose: "{{event}}" }, { record: decomposed }]
      start:
        - by: [platform]
          guard: params.auto_decompose
          target: triaging
        - by: [manager]   # specify or decompose asked with no spec: a session writes it
          target: triaging

  triaging:   # ours: triage by a session in the card's lane
    stored_as: running
    run:
      role: implementer
      session: worker
      prompt: |
        Card {{card.id}} on the {{board}} board is in triage: a rough idea to split. Read it, then file the cards it
        breaks into and make it wait on them, or write its spec.
        {{doors}}

        {{context}}
    on:
      specify: [{ by: [implementer], target: todo, actions: [{ end_run: { outcome: specified } }, { specify: "{{event}}" }, { record: specified }] }]
      decompose: [{ by: [implementer], target: todo, actions: [{ end_run: { outcome: decomposed } }, { decompose: "{{event}}" }, { record: decomposed }] }]
      spawn_failed:   # the launch itself failed: back where it came from, counted against the breaker
        - by: [platform]
          guard: "card.counters.failures + 1 >= (card.max_retries ?? params.failure_limit)"
          target: blocked
          actions: [{ end_run: { outcome: spawn_failed } }, { count: failures }, { record: spawn_failed }, { record: gave_up }]
        - by: [platform]
          target: triage
          actions: [{ end_run: { outcome: spawn_failed } }, { count: failures }, { record: spawn_failed }]
      session_idle:   # ours: the heartbeat, with the same budget as the implementer's
        - by: [platform]
          guard: "event.turns >= (card.goal_max_turns ?? params.goal_max_turns)"
          target: blocked
          actions: [{ end_run: { outcome: blocked } }, { assign: { field: block_kind, value: needs_input } }, { record: { kind: blocked, payload: { reason: "its triage session went idle {{event.turns}} times without deciding; review it", kind: needs_input, source_status: triage } } }]
        - by: [platform]
          actions:
            - count: goal_turns
            - send_to_actor: "Card {{card.id}} ({{card.title}}) is waiting for you to decide ({{event.turns + 1}} of {{card.goal_max_turns ?? params.goal_max_turns}}).\n{{doors}}"
            - record: { kind: decision_asked, payload: { turn: "{{event.turns + 1}}", budget: "{{card.goal_max_turns ?? params.goal_max_turns}}" } }
      machine_offline:   # ours: a session whose machine stays off the fleet past the grace
        - by: [platform]
          guard: "event.seconds >= params.machine_offline_grace_seconds"
          target: blocked
          actions: [{ end_run: { outcome: reclaimed } }, { assign: { field: block_kind, value: capability } }, { record: { kind: blocked, payload: { reason: "machine {{event.machine}} has been off the fleet for {{event.seconds}}s", kind: capability, source_status: triage } } }]
      session_lost: [{ by: [platform], target: triage, actions: [{ end_run: { outcome: reclaimed } }, { record: session_lost }] }]
      orphaned: [{ by: [platform], target: triage, actions: [{ end_run: { outcome: reclaimed } }, { record: reconciled }, { comment: "Requeued: the card was running with no claim and nothing live behind it." }] }]
      exited: [{ by: [platform], target: triage, actions: [{ end_run: { outcome: crashed } }, { record: crashed }] }]

  todo:
    stored_as: todo
    description: waiting on its parents
    always:
      - guard: "card.arc != null && card.arc.status in ['done', 'archived']"   # ours: a subtask whose arc ended with it open
        target: blocked
        actions: [{ assign: { field: block_kind, value: needs_input } }, { record: { kind: blocked, payload: { reason: "its arc {{card.arc.id}} ended with it open", kind: needs_input, source_status: ready } } }]
      - guard: "card.parents.all(p, p.status in ['done', 'archived'])"   # recompute_ready
        target: ready
        actions: [{ record: promoted }]
    on:
      promote:
        - validate: [{ expr: "event.force || card.parents.all(p, p.status in ['done', 'archived'])", message: "parents not done (force to override)" }]
          target: ready
          actions: [{ record: promoted_manual }]
      schedule: [{ target: scheduled, actions: [{ record: scheduled }] }]

  ready:
    stored_as: ready
    description: waiting for the dispatcher to start it
    always:
      - guard: "card.arc != null && card.arc.status in ['done', 'archived']"   # ours: a subtask whose arc ended with it open
        target: blocked
        actions: [{ assign: { field: block_kind, value: needs_input } }, { record: { kind: blocked, payload: { reason: "its arc {{card.arc.id}} ended with it open", kind: needs_input, source_status: ready } } }]
      - guard: "!card.parents.all(p, p.status in ['done', 'archived'])"   # a parent linked after it was ready
        target: todo
    on:
      start:   # claim_task, under dispatch_once's respawn guard
        - by: [platform]
          validate:
            - expr: "!(card.last_run.outcome == 'rate_limited' && now - card.last_run.ended_at < params.rate_limit_cooldown_seconds)"
              message: rate_limit_cooldown
            - expr: "!matches(card.last_failure_error, params.blocker_pattern)"
              message: blocker_auth
            - expr: "!(card.last_completed != null && now - card.last_completed.ended_at < params.recent_success_seconds && card.events_since(card.last_completed.ended_at, ['status', 'promoted', 'unblocked', 'reclaimed']).size() == 0)"
              message: recent_success
            - expr: "!card.comments_since(now - params.active_pr_seconds).exists(c, matches(c.body, params.pr_pattern))"
              message: active_pr
          target: running
          actions: [{ claim: implementer }]
      block:
        - guard: "event.kind == 'dependency'"
          target: todo
          actions: [{ assign: { field: block_kind, value: "{{event.kind}}" } }, { record: dependency_wait }]
        - guard: "card.block_kind == event.kind && card.counters.block_recurrences + 1 >= params.block_recurrence_limit"
          target: triage
          actions: [{ count: block_recurrences }, { record: block_loop_detected }]
        - target: blocked
          actions: [{ count: block_recurrences }, { assign: { field: block_kind, value: "{{event.kind}}" } }, { record: blocked }]
      request_review:
        - target: review
          actions: [{ assign: { field: assignee, value: "{{event.reviewer ?? card.last_reviewer ?? card.assignee}}" } }, { record: review_requested }]
      complete:
        - validate: [{ expr: "card.parents.all(p, p.status in ['done', 'archived'])", message: "the card waits on parents that are not done" }]
          target: done
          actions: [{ end_run: { outcome: completed } }, { set_result: "{{event}}" }, { reset: [failures, block_recurrences] }, { assign: { field: last_failure_error, value: "{{null}}" } }, { assign: { field: block_kind, value: "{{null}}" } }, { cleanup_workspace: null }, { record: completed }, { check_references: "{{event}}" }]
      schedule: [{ target: scheduled, actions: [{ record: scheduled }] }]

  running:
    stored_as: running
    description: its implementer is working it
    run:
      role: implementer
      session: worker
      prompt: |
        You are the session working card {{card.id}} on the {{board}} board. The board started you; updates to the
        card and to the cards it waits on reach you as board notices.
        {{doors}}
        Leave a note on it with `supercode workflow comment {{card.id}} "<text>" {{where}}`; file a subtask with
        `supercode workflow create "<title>" --subtask-of {{card.id}} {{where}}`.

        {{context}}
      limits:
        runtime: card.max_runtime_seconds
        stale: "run.surface == 'headless' ? params.dispatch_stale_timeout_seconds : null"
        grace: params.session_grace_seconds
    on:
      heartbeat: [{ by: [implementer], description: 'still working on a long step (`--note "<what>"`)', actions: [{ extend_claim: null }, { record: heartbeat }] }]
      complete:
        - by: [implementer, manager]
          description: 'the work is done: `--summary "<what you did and how it was verified>"`'
          validate:
            - { expr: "event.run_id == null || event.run_id == card.current_run_id", message: "that run is no longer the card's current run" }
            - { expr: "card.parents.all(p, p.status in ['done', 'archived'])", message: "the card waits on parents that are not done" }
          target: done
          actions: [{ end_run: { outcome: completed } }, { set_result: "{{event}}" }, { reset: [failures, block_recurrences] }, { assign: { field: last_failure_error, value: "{{null}}" } }, { assign: { field: block_kind, value: "{{null}}" } }, { cleanup_workspace: null }, { record: completed }, { check_references: "{{event}}" }]
      block:
        - by: [implementer, manager]
          description: 'you cannot go on: `"<why>" --kind needs_input|capability|transient|dependency`'
          guard: "event.kind == 'dependency'"
          target: todo
          actions: [{ end_run: { outcome: blocked } }, { assign: { field: block_kind, value: "{{event.kind}}" } }, { record: dependency_wait }]
        - by: [implementer, manager]
          guard: "card.block_kind == event.kind && card.counters.block_recurrences + 1 >= params.block_recurrence_limit"
          target: triage
          actions: [{ end_run: { outcome: blocked } }, { count: block_recurrences }, { record: block_loop_detected }]
        - by: [implementer, manager]
          target: blocked
          actions: [{ end_run: { outcome: blocked } }, { count: block_recurrences }, { assign: { field: block_kind, value: "{{event.kind}}" } }, { record: blocked }]
      request_review:
        - by: [implementer, manager]
          description: 'the work is ready for review: `--summary "<what to review>"`'
          validate: [{ expr: "event.run_id == card.current_run_id || event.force", message: "the card is running under a live claim; its worker requests review, or pass --force" }]
          target: review
          actions: [{ end_run: { outcome: review_requested } }, { assign: { field: assignee, value: "{{event.reviewer ?? card.last_reviewer ?? card.assignee}}" } }, { record: review_requested }]
      reclaim: [{ by: [manager], target: ready, actions: [{ end_run: { outcome: reclaimed } }, { reset: [failures] }, { record: reclaimed }] }]
      schedule: [{ by: [manager], target: scheduled, actions: [{ end_run: { outcome: scheduled } }, { record: scheduled }] }]
      # detect_crashed_workers / enforce_max_runtime / release_stale_claims, with the breaker (a card's max_retries wins)
      exited:
        - by: [platform]
          guard: "event.code == 75"
          target: ready
          actions: [{ end_run: { outcome: rate_limited } }, { record: rate_limited }]
        - by: [platform]   # a clean exit that left the card running is a protocol violation: the breaker trips at once
          guard: "event.code == 0"
          target: blocked
          actions: [{ end_run: { outcome: protocol_violation } }, { count: failures }, { record: crashed }, { record: gave_up }]
        - by: [platform]
          guard: "card.counters.failures + 1 >= (card.max_retries ?? params.failure_limit)"
          target: blocked
          actions: [{ end_run: { outcome: "{{event.code == 0 ? 'protocol_violation' : 'crashed'}}" } }, { count: failures }, { record: crashed }, { record: gave_up }]
        - by: [platform]
          target: ready
          actions: [{ end_run: { outcome: "{{event.code == 0 ? 'protocol_violation' : 'crashed'}}" } }, { count: failures }, { record: crashed }]
      spawn_failed:   # the launch itself failed: back where it came from, counted against the breaker
        - by: [platform]
          guard: "card.counters.failures + 1 >= (card.max_retries ?? params.failure_limit)"
          target: blocked
          actions: [{ end_run: { outcome: spawn_failed } }, { count: failures }, { record: spawn_failed }, { record: gave_up }]
        - by: [platform]
          target: ready
          actions: [{ end_run: { outcome: spawn_failed } }, { count: failures }, { record: spawn_failed }]
      timed_out:
        - by: [platform]
          guard: "card.counters.failures + 1 >= (card.max_retries ?? params.failure_limit)"
          target: blocked
          actions: [{ stop_run: null }, { end_run: { outcome: timed_out } }, { count: failures }, { record: timed_out }, { record: gave_up }]
        - by: [platform]
          target: ready
          actions: [{ stop_run: null }, { end_run: { outcome: timed_out } }, { count: failures }, { record: timed_out }]
      orphaned: [{ by: [platform], target: ready, actions: [{ end_run: { outcome: reclaimed } }, { record: reconciled }, { comment: "Requeued: the card was running with no claim and nothing live behind it." }] }]
      stale: [{ by: [platform], target: ready, actions: [{ stop_run: null }, { end_run: { outcome: stale } }, { record: stale }] }]
      session_lost:   # ours: a pane session gone past its grace is resumed at the next start, never replaced first
        - by: [platform]   # a fresh session that never came up is a failure
          guard: "event.never_came_up && card.counters.failures + 1 >= (card.max_retries ?? params.failure_limit)"
          target: blocked
          actions: [{ end_run: { outcome: reclaimed } }, { count: failures }, { record: session_lost }, { record: gave_up }]
        - by: [platform]
          guard: event.never_came_up
          target: ready
          actions: [{ end_run: { outcome: reclaimed } }, { count: failures }, { record: session_lost }]
        - by: [platform]
          target: ready
          actions: [{ end_run: { outcome: reclaimed } }, { record: session_lost }]
      machine_offline:   # ours: a session whose machine stays off the fleet past the grace
        - by: [platform]
          guard: "event.seconds >= params.machine_offline_grace_seconds"
          target: blocked
          actions: [{ end_run: { outcome: reclaimed } }, { assign: { field: block_kind, value: capability } }, { record: { kind: blocked, payload: { reason: "machine {{event.machine}} has been off the fleet for {{event.seconds}}s", kind: capability, source_status: ready } } }]
      session_idle:   # ours: the heartbeat. event.turns: asks so far this run; event.worked: seen working since the last ask
        - by: [platform]
          guard: "(card.goal_mode || !event.worked) && event.turns >= (card.goal_max_turns ?? params.goal_max_turns)"
          target: blocked
          actions:
            - end_run: { outcome: blocked }
            - assign: { field: block_kind, value: needs_input }
            - record: { kind: blocked, payload: { reason: "its session went idle {{event.turns}} times without deciding done or blocked; review it", kind: needs_input, source_status: ready } }
        - by: [platform]
          guard: card.goal_mode
          actions:
            - count: goal_turns
            - send_to_actor: "Card {{card.id}} ({{card.title}}) is not done yet: keep working toward it (goal turn {{event.turns + 1}} of {{card.goal_max_turns ?? params.goal_max_turns}}).\n{{doors}}"
            - record: { kind: goal_continued, payload: { turn: "{{event.turns + 1}}", budget: "{{card.goal_max_turns ?? params.goal_max_turns}}" } }
        - by: [platform]
          actions:
            - reset: "{{event.worked ? ['goal_turns'] : []}}"
            - count: goal_turns
            - send_to_actor: "Card {{card.id}} ({{card.title}}) is still running and you are idle: decide ({{(event.worked ? 0 : event.turns) + 1}} of {{card.goal_max_turns ?? params.goal_max_turns}}). If there is more to do, keep working. A session that stays idle without deciding has its card blocked for its creator.\n{{doors}}"
            - record: { kind: decision_asked, payload: { turn: "{{(event.worked ? 0 : event.turns) + 1}}", budget: "{{card.goal_max_turns ?? params.goal_max_turns}}" } }

  review:
    stored_as: review
    description: its implementer asked for review
    on:
      start:   # claim_review_task
        - by: [platform]
          guard: params.review_dispatch
          validate:
            - expr: "!(card.last_run.outcome == 'rate_limited' && now - card.last_run.ended_at < params.rate_limit_cooldown_seconds)"
              message: rate_limit_cooldown
            - expr: "!matches(card.last_failure_error, params.blocker_pattern)"
              message: blocker_auth
          target: reviewing
          actions: [{ claim: reviewer }]
      complete:
        - by: [reviewer, manager]
          description: 'the work is done: `--summary "<what you did and how it was verified>"`'
          validate: [{ expr: "card.parents.all(p, p.status in ['done', 'archived'])", message: "the card waits on parents that are not done" }]
          target: done
          actions: [{ end_run: { outcome: completed, summary: "{{event.summary ?? 'Review approved without additional evidence.'}}" } }, { set_result: "{{event}}" }, { reset: [failures, block_recurrences] }, { assign: { field: last_failure_error, value: "{{null}}" } }, { assign: { field: block_kind, value: "{{null}}" } }, { cleanup_workspace: null }, { record: completed }, { check_references: "{{event}}" }]
      request_changes:   # request_changes: back to the recorded implementer
        - by: [reviewer, manager]
          target: "{{card.parents.all(p, p.status in ['done', 'archived']) ? 'ready' : 'todo'}}"
          actions: [{ assign: { field: assignee, value: "{{card.implementer}}" } }, { record: changes_requested }]
      reopen_review:
        - by: [manager]
          target: "{{card.parents.all(p, p.status in ['done', 'archived']) ? 'ready' : 'todo'}}"
          actions: [{ assign: { field: assignee, value: "{{card.implementer}}" } }, { record: review_reopened }]
      block:
        - target: blocked
          actions: [{ assign: { field: block_kind, value: "{{event.kind}}" } }, { record: blocked }]

  reviewing:
    stored_as: running
    description: a reviewer is reviewing it
    run:
      role: reviewer
      session: reviewer
      prompt: |
        You are reviewing card {{card.id}} on the {{board}} board: its implementer asked for review. Verify the
        handoff against the card's acceptance, then give the verdict.
        {{doors}}

        {{context}}
      skills: [sdlc-review]
      limits:
        runtime: card.max_runtime_seconds
        grace: params.session_grace_seconds
    exit: [{ close_session: reviewer }]
    on:
      complete:
        - by: [reviewer, manager]
          description: 'the work is done: `--summary "<what you did and how it was verified>"`'
          validate: [{ expr: "card.parents.all(p, p.status in ['done', 'archived'])", message: "the card waits on parents that are not done" }]
          target: done
          actions: [{ end_run: { outcome: completed } }, { set_result: "{{event}}" }, { reset: [failures, block_recurrences] }, { assign: { field: last_failure_error, value: "{{null}}" } }, { assign: { field: block_kind, value: "{{null}}" } }, { cleanup_workspace: null }, { record: completed }, { check_references: "{{event}}" }]
      request_changes:
        - by: [reviewer, manager]
          description: 'send it back to its implementer: `"<what must change>"`'
          target: "{{card.parents.all(p, p.status in ['done', 'archived']) ? 'ready' : 'todo'}}"
          actions: [{ end_run: { outcome: changes_requested } }, { assign: { field: assignee, value: "{{card.implementer}}" } }, { record: changes_requested }]
      block:
        - by: [reviewer, manager]
          description: 'you cannot go on: `"<why>" --kind needs_input|capability|transient|dependency`'
          target: blocked
          actions: [{ end_run: { outcome: blocked } }, { assign: { field: block_kind, value: "{{event.kind}}" } }, { record: blocked }]
      exited:
        - by: [platform]
          target: review
          actions: [{ end_run: { outcome: crashed } }, { count: failures }, { record: crashed }]
      spawn_failed:   # the launch itself failed: back where it came from, counted against the breaker
        - by: [platform]
          guard: "card.counters.failures + 1 >= (card.max_retries ?? params.failure_limit)"
          target: blocked
          actions: [{ end_run: { outcome: spawn_failed } }, { count: failures }, { record: spawn_failed }, { record: gave_up }]
        - by: [platform]
          target: review
          actions: [{ end_run: { outcome: spawn_failed } }, { count: failures }, { record: spawn_failed }]
      timed_out: [{ by: [platform], target: review, actions: [{ stop_run: null }, { end_run: { outcome: timed_out } }, { count: failures }, { record: timed_out }] }]
      session_lost: [{ by: [platform], target: review, actions: [{ end_run: { outcome: reclaimed } }, { record: session_lost }] }]
      orphaned: [{ by: [platform], target: review, actions: [{ end_run: { outcome: reclaimed } }, { record: reconciled }, { comment: "Requeued: the card was running with no claim and nothing live behind it." }] }]
      session_idle:   # ours: the heartbeat, with the same budget as the implementer's
        - by: [platform]
          guard: "event.turns >= (card.goal_max_turns ?? params.goal_max_turns)"
          target: blocked
          actions: [{ end_run: { outcome: blocked } }, { assign: { field: block_kind, value: needs_input } }, { record: { kind: blocked, payload: { reason: "its reviewer went idle {{event.turns}} times without deciding; review it", kind: needs_input, source_status: review } } }]
        - by: [platform]
          actions:
            - count: goal_turns
            - send_to_actor: "Card {{card.id}} ({{card.title}}) is waiting for you to decide ({{event.turns + 1}} of {{card.goal_max_turns ?? params.goal_max_turns}}).\n{{doors}}"
            - record: { kind: decision_asked, payload: { turn: "{{event.turns + 1}}", budget: "{{card.goal_max_turns ?? params.goal_max_turns}}" } }
      machine_offline:   # ours: a session whose machine stays off the fleet past the grace
        - by: [platform]
          guard: "event.seconds >= params.machine_offline_grace_seconds"
          target: blocked
          actions: [{ end_run: { outcome: reclaimed } }, { assign: { field: block_kind, value: capability } }, { record: { kind: blocked, payload: { reason: "machine {{event.machine}} has been off the fleet for {{event.seconds}}s", kind: capability, source_status: review } } }]
  blocked:
    stored_as: blocked
    description: waiting on a person, a capability, or a transient cause
    always:   # recompute_ready: a card not blocked by a person, under its failure limit, comes back when its parents are done
      - guard: "card.last_block_event != 'blocked' && card.counters.failures < (card.max_retries ?? params.failure_limit) && card.parents.all(p, p.status in ['done', 'archived'])"
        target: "{{card.resume_status}}"
        actions: [{ record: promoted }]
    on:
      unblock:   # unblock_task: back where it was blocked from
        - target: "{{card.parents.all(p, p.status in ['done', 'archived']) ? card.resume_status : 'todo'}}"
          actions: [{ reset: [failures] }, { assign: { field: last_failure_error, value: "{{null}}" } }, { record: unblocked }]
      promote:
        - validate: [{ expr: "event.force || card.parents.all(p, p.status in ['done', 'archived'])", message: "parents not done (force to override)" }]
          target: ready
          actions: [{ record: promoted_manual }]
      complete:
        - validate: [{ expr: "card.parents.all(p, p.status in ['done', 'archived'])", message: "the card waits on parents that are not done" }]
          target: done
          actions: [{ set_result: "{{event}}" }, { reset: [failures, block_recurrences] }, { assign: { field: last_failure_error, value: "{{null}}" } }, { assign: { field: block_kind, value: "{{null}}" } }, { record: completed }, { check_references: "{{event}}" }]
      schedule: [{ target: scheduled, actions: [{ record: scheduled }] }]

  scheduled:
    stored_as: scheduled
    description: set aside until someone brings it back
    on:
      unblock: [{ target: ready, actions: [{ record: unblocked }] }]

  done:
    stored_as: done
    description: finished
    on:
      edit: [{ actions: [{ set_result: "{{event}}" }, { record: edited }] }]
      reopen:   # the dashboard's reopen, with invalidate_descendants_for_parent_reopen
        - target: "{{card.parents.all(p, p.status in ['done', 'archived']) ? 'ready' : 'todo'}}"
          actions: [{ invalidate_descendants: null }, { record: status }]

  archived:
    stored_as: archived
    description: out of the way
    on:
      reopen:
        - target: "{{card.parents.all(p, p.status in ['done', 'archived']) ? 'ready' : 'todo'}}"
          actions: [{ invalidate_descendants: null }, { record: status }]

dispatch:
  serve: params.dispatch_in_gateway
  tick: params.dispatch_interval_seconds
  start: start
  # a subtask is worked by its arc's session; a card this machine's memory cannot take waits (dispatch_once)
  eligible: "card.claim_lock == null && card.subtask_of == null && !(run.local && (host.memory_pressure == 'critical' || (host.memory_pressure == 'elevated' && tick.local_started >= 1)))"
  order: ["card.status == 'review' ? 1 : 0", "-card.priority", "card.created_at"]
  limits:
    - description: the home runs this many cards at most across its boards (kanban.max_in_progress)
      group: "'home'"
      counts: "card.stored_as == 'running'"
      max: params.max_in_progress ?? host.max_in_progress
      reserve: { for: "card.status == 'review'", slots: 1 }
    - description: the board runs this many cards at most (kanban.max_spawn)
      group: card.board
      counts: "card.stored_as == 'running'"
      max: params.max_spawn
    - description: the profile's capacity (worker.capacity, else kanban.max_in_progress_per_profile)
      group: card.assignee
      counts: "card.stored_as == 'running'"
      max: lane.capacity ?? params.max_in_progress_per_profile
    - description: the machine's capacity; an idle session on a done or blocked card holds its place until closed (ours)
      group: card.machine
      counts: "card.stored_as == 'running' || card.session_live"
      max: "params.machines[card.machine].capacity"
    - description: triage sessions started per tick (kanban.auto_decompose_per_tick)
      group: "'triage'"
      counts: "card.status == 'triaging' && card.started_this_tick"
      max: params.auto_decompose_per_tick