Repository navigation

Drain DeferredBusy messages when the blocking run reaches terminal state - #4812

Closed

henrypark133 wants to merge 21 commits into

mainfrom

feat/deferred-busy-drain

Commits on Jun 12, 2026

feat(threads): add list_deferred_busy_messages to SessionThreadService

henrypark133
and
claude
committed
6c181b8
feat(reborn): drain DeferredBusy messages on run terminal event

henrypark133
and
claude
committed
195d834
test(reborn): add drain observer integration and idempotency tests

henrypark133
and
claude
committed
bdca07d
fix(reborn): refuse to drain deferred messages without a recorded actor

henrypark133
and
claude
committed
0f79759
fix(threads): add limit to ListDeferredBusyMessagesRequest to cap history scan

henrypark133
and
claude
committed
242cf33
fix(product_workflow): expose bounded binding ref helpers as pub for drain reuse

henrypark133
and
claude
committed
2e2c565
fix(reborn): drain deferred messages on runner-origin terminal state (publish_state path)

henrypark133
and
claude
committed
37dbd35
test(e2e): wire additional_required_observers into reborn binary harness

henrypark133
and
claude
committed
72ad241
fix(threads): persist canonical binding refs, paginated deferred list, and presence-marker fast path

henrypark133
and
claude
committed
f45a562
fix(callers): update all mark_message_deferred_busy and ThreadMessageRecord sites for new fields

henrypark133
and
claude
committed
9c57fcb
feat(composition): rewrite drain with canonical-ref replay, windowed pagination, and cap

henrypark133
and
claude
committed
6757cc4
fix(review): address PR #4812 review comments

henrypark133
and
claude
committed
f2600cc
Merge origin/main into feat/deferred-busy-drain

henrypark133
and
claude
committed
81b561c
fix(threads,webui): scrub replay refs from public reads; fix marker race

henrypark133
and
claude
committed
02f1f18
fix(reborn,composition): canonical scope resolver in drain, facade-level ref scrub

henrypark133
and
claude
committed
ba5f6ed
Merge branch 'main' into feat/deferred-busy-drain
henrypark133
authored
7418309
fix(threads,composition): pre-limit tombstone count, module split, ref-replay assertions

henrypark133
and
claude
committed
18bb5b3
Merge branch 'feat/deferred-busy-drain' of github.com:nearai/ironclaw into feat/deferred-busy-drain
henrypark133
committed
c9b956a
fix(product_workflow): retry submit once after defer commits to close timing gap

henrypark133
and
claude
committed
8cff5cc
fix(product_workflow,composition): retry-blocker payload, drain logging, coverage

henrypark133
and
claude
committed
0c3fd56
fix(threads,composition): drain replays the original idempotency key

henrypark133
and
claude
committed
d40728e

Navigation Menu

Repository navigation

Drain DeferredBusy messages when the blocking run reaches terminal state - #4812

Drain DeferredBusy messages when the blocking run reaches terminal state#4812
henrypark133 wants to merge 21 commits into
mainfrom
feat/deferred-busy-drain

Commits on Jun 12, 2026

feat(threads): add list_deferred_busy_messages to SessionThreadService

feat(reborn): drain DeferredBusy messages on run terminal event

test(reborn): add drain observer integration and idempotency tests

fix(reborn): refuse to drain deferred messages without a recorded actor

fix(threads): add limit to ListDeferredBusyMessagesRequest to cap history scan

fix(product_workflow): expose bounded binding ref helpers as pub for drain reuse

fix(reborn): drain deferred messages on runner-origin terminal state (publish_state path)

test(e2e): wire additional_required_observers into reborn binary harness

fix(threads): persist canonical binding refs, paginated deferred list, and presence-marker fast path

fix(callers): update all mark_message_deferred_busy and ThreadMessageRecord sites for new fields

feat(composition): rewrite drain with canonical-ref replay, windowed pagination, and cap

fix(review): address PR #4812 review comments

Merge origin/main into feat/deferred-busy-drain

fix(threads,webui): scrub replay refs from public reads; fix marker race

fix(reborn,composition): canonical scope resolver in drain, facade-level ref scrub

Merge branch 'main' into feat/deferred-busy-drain

fix(threads,composition): pre-limit tombstone count, module split, ref-replay assertions

Merge branch 'feat/deferred-busy-drain' of github.com:nearai/ironclaw into feat/deferred-busy-drain

fix(product_workflow): retry submit once after defer commits to close timing gap

fix(product_workflow,composition): retry-blocker payload, drain logging, coverage

fix(threads,composition): drain replays the original idempotency key