lsm / neokai / 25178728887

82%

push

github

Fix queued workflow handoff recovery (#1738)

* Fix queued workflow handoff recovery

Make workflow node handoffs bounded and recoverable by adding runtime repair for pending node-agent messages and stable idempotency for queued sends.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

* Harden queued handoff repair.

Block expired queued handoffs, avoid duplicate activation races, and cover the repair loop with regression tests so stuck handoffs surface as actionable workflow failures.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

* Preserve terminal tasks during handoff expiry.

Handle terminal queued handoffs before expiry blocking so completed tasks are not regressed to blocked when stale handoff rows age out.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

* Address queued handoff review comments.

Respect pause semantics, surface exhausted flush failures, and scope queued-message idempotency to live pending rows so repaired history cannot hide later handoffs.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

* Remove redundant node execution refresh.

Avoid an unnecessary duplicate repository read after queued handoff repair before computing pending executions.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

* Tighten handoff retry bookkeeping.

Limit flush-failure blocking to the current pending batch and encode queued handoff idempotency as a structured tuple to avoid ambiguous collisions.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

* Skip queued handoff repair during rebind recovery.

Avoid spawning or flushing queued handoff messages into executions that are waiting for durable tool-continuation rebind recovery.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

* Avoid rebind resume during handoff repair.

Check queued handoff target execution state before attempting resume so waiting-rebind recovery cannot receive queued messages through the resume path.

Co-Authored-By: C... (continued)

7709 of 10042 branches covered (76.77%)

Branch coverage included in aggregate %.

279 of 279 new or added lines in 4 files covered. (100.0%)

59642 of 83582 relevant lines covered (71.36%)

252.98 hits per line