lsm / neokai / 25836138429

81%

Build Type

push

github

Committed by web-flow

Commit Message

Wire workflow runtime external event delivery (#1886)

* feat: deliver external events to workflow node agents

Wire workflow runtimes to match node-agent event interests, track delivery state, and queue pending-node events for later injection.

* fix: harden workflow external event delivery

Validate event-interest topics, prevent stale or duplicate pending deliveries, and keep runtime subscriptions safe across restarts.

* fix: handle external event retry edge cases

* fix: avoid stale external event sessions

* fix: preserve external event deliveries during rehydrate

* fix: merge external event app wiring

* fix: drain external event retries safely

* fix: wire runtime external event config

* fix: keep external event retries draining

* fix: dedupe external event delivery attempts

* fix: harden external event delivery lifecycle

* fix: register active external event interests

* fix: queue inactive external event targets

* fix: harden external event subscription matching

Avoid delivery attempts for blocked runs that have no active execution path and dedupe matching delivery keys before dispatch.

* fix: refresh external event subscriptions

Keep workflow event interests current during runtime definition updates and re-evaluate stranded published events after rehydrate.

* fix: drain stale external event deliveries

* fix: remove duplicate EventInterest interface

* fix: terminalize undeliverable external event targets and sweep on start

* fix: guard transient retry against terminal run transition

* fix: guard transient retry against blocked run without active execution

The transient-error catch path in deliverToSession now also checks
whether a blocked run has active node executions before queueing a
retry. Without this check, a run that transitioned to blocked with
no active executions during an in-flight dispatch would keep retrying
instead of terminalizing the delivery.

* fix: re-register interests when recovering a terminal workflow ru... (continued)

Coverage Stats

8333 of 11605 branches covered (71.81%)

Branch coverage included in aggregate %.

679 of 698 new or added lines in 7 files covered. (97.28%)

1 existing line in 1 file now uncovered.

66605 of 79320 relevant lines covered (83.97%)

292.31 hits per line