Skip to content

feat(supervise): event bus priority bump + A++ observability#317

Merged
drewstone merged 1 commit into
mainfrom
feat/bus-priority-observability
Jun 16, 2026
Merged

feat(supervise): event bus priority bump + A++ observability#317
drewstone merged 1 commit into
mainfrom
feat/bus-priority-observability

Conversation

@drewstone

Copy link
Copy Markdown
Contributor

Upgrades the child→parent coordination bus (#316) from FIFO into the real core that backs ~all supervisor↔worker interactions.

What changed

  • Priority pull (the bump). A blocking question (urgency→priority: blocks-run=20, blocks-step=10) is pulled ahead of queued settles/findings so the driver sees it first; ties resolve FIFO by seq. Pass-through (subscribe/onEvent) still delivers the instant it's raised.
  • A++ observability. Every event is stamped (seq/at/priority); history() is the full ordered audit/replay trail; stats() counts published/pulled/by-kind. Surfaced on CoordinationTools and the serveCoordinationMcp handle.
  • Generalized questions. ask_parent questions are now bus events carrying urgency-derived priority — one mechanism, not a side channel. peek() + unsubscribe round out the primitive.

Why

One typed node↔node primitive: settled / question / finding are all events; new interaction kinds are additive; the in-process queue and a future cross-box durable mailbox share the same interface.

Verification

  • bus 6 + coordination 10 tests (priority bump, peek, history/stats, unsubscribe, analyze-on-settle)
  • full suite 999 pass; typecheck / build / lint clean
  • merges cleanly into main

Upgrade the child→parent bus from FIFO to the real coordination core:
- PRIORITY pull — a blocking question (urgency→priority: blocks-run=20, blocks-step=10)
  bumps ahead of queued settles/findings so the driver sees it first; ties FIFO by seq.
  Pass-through (subscribe/onEvent) still delivers immediately.
- Observability A++ — every event stamped (seq/at/priority); history() is the full
  ordered audit/replay trail; stats() counts published/pulled/by-kind. Surfaced on
  CoordinationTools and the serveCoordinationMcp handle.
- Generalized questions — ask_parent questions are bus events carrying urgency-derived
  priority; peek() + unsubscribe round out the primitive.

bus 6 + coordination 10 tests; full suite 999 pass; typecheck/build/lint clean.

@tangletools tangletools left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

✅ Auto-approved PR — a7ee7026

Blanket team auto-approval is enabled for this reviewer service.
The full PR reviewer audit still runs separately and will publish findings if it detects issues.

tangletools · auto-approval · reason: blanket_auto_approve · 2026-06-16T20:19:48Z

@drewstone drewstone merged commit bc5cf78 into main Jun 16, 2026
1 check passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants