Skip to content

fix(gastown): skip container_status events for running containers#1368

Merged
jrf0110 merged 1 commit intoconvoy/reconciler-phase-5-debug-endpoints-grafa/4763028e/headfrom
convoy/reconciler-phase-5-debug-endpoints-grafa/4763028e/gt/toast/a27dfa14
Mar 21, 2026
Merged

fix(gastown): skip container_status events for running containers#1368
jrf0110 merged 1 commit intoconvoy/reconciler-phase-5-debug-endpoints-grafa/4763028e/headfrom
convoy/reconciler-phase-5-debug-endpoints-grafa/4763028e/gt/toast/a27dfa14

Conversation

@jrf0110
Copy link
Copy Markdown
Contributor

@jrf0110 jrf0110 commented Mar 21, 2026

Summary

Skip inserting container_status events when the container reports running status. Running is the steady-state for healthy agents and is a no-op in applyEvent() (the reconciler only acts on exited or not_found). This eliminates ~720 no-op events/hour/agent from the town_events table. Non-running statuses (stopped, error, unknown, exited, not_found) continue to generate events for reconciler detection.

Verification

  • Typecheck (pnpm typecheck) — pass (per polecat)
  • oxlint — pass (per polecat)
  • Format — pass (per polecat)
  • Code review — confirmed applyEvent only acts on exited/not_found, so filtering running is safe

Visual Changes

N/A

Reviewer Notes

  • The existing dedup logic in upsertContainerStatus() (events.ts:75-139) already mitigated the volume problem by bumping timestamps instead of inserting new rows for same-status repeats. This change goes further by not calling upsertContainerStatus() at all for running, avoiding even the SELECT+UPDATE overhead.
  • The comment mentions "stopped, error, unknown" as non-running statuses that still get inserted. The reconciler currently only handles exited and not_found — the others are also no-ops in applyEvent today but are preserved as audit trail for non-steady-state conditions.

Filter out 'running' status in the alarm pre-phase before calling
upsertContainerStatus(). Running is the steady-state for healthy agents
and a no-op in applyEvent(), so recording it just bloats the event table
(~720 events/hour/agent). Non-running statuses (stopped, error, unknown)
still get inserted for reconciler detection.
@kilo-code-bot
Copy link
Copy Markdown
Contributor

kilo-code-bot Bot commented Mar 21, 2026

Code Review Summary

Status: No Issues Found | Recommendation: Merge

Files Reviewed (1 files)
  • cloudflare-gastown/src/dos/Town.do.ts

Reviewed by gpt-5.4-20260305 · 411,362 tokens

@jrf0110 jrf0110 merged commit 49754d6 into convoy/reconciler-phase-5-debug-endpoints-grafa/4763028e/head Mar 21, 2026
2 checks passed
@jrf0110 jrf0110 deleted the convoy/reconciler-phase-5-debug-endpoints-grafa/4763028e/gt/toast/a27dfa14 branch March 21, 2026 16:15
jrf0110 added a commit that referenced this pull request Mar 24, 2026
#1373)

* fix: skip container_status events for running containers (#1368)

Filter out 'running' status in the alarm pre-phase before calling
upsertContainerStatus(). Running is the steady-state for healthy agents
and a no-op in applyEvent(), so recording it just bloats the event table
(~720 events/hour/agent). Non-running statuses (stopped, error, unknown)
still get inserted for reconciler detection.

* feat(gastown): add POST /debug/reconcile-dry-run endpoint (#1367)

Add a debug endpoint that runs the reconciler against current live state
and returns the actions it would emit without applying them. This enables
inspecting what the reconciler thinks should happen at any given moment.

- Add debugDryRun() method to TownDO that calls reconciler.reconcile()
  and returns actions + metrics without calling applyAction()
- Add POST /debug/towns/:townId/reconcile-dry-run route following the
  same unauthenticated debug pattern as GET /debug/towns/:townId/status
- Response includes actions array, actionsEmitted count, actionsByType
  breakdown, and pendingEventCount

* feat(gastown): add debug dry-run endpoint with event draining (#1370)

* feat(claw): evaluate button-vs-card feature flag for PostHog experiment tracking

* fix(claw): move button-vs-card flag eval to CreateInstanceCard

Moves useFeatureFlagVariantKey('button-vs-card') from ClawDashboard
(which renders for all users including those with existing instances)
to CreateInstanceCard (which only renders for users who haven't
provisioned yet). This scopes the experiment exposure to users who
can actually see the create CTA, avoiding population dilution.

* feat(gastown): add POST /debug/reconcile-dry-run endpoint

Add a debug endpoint that runs the reconciler against current live state
and returns the actions it would emit without applying them. This enables
inspecting what the reconciler thinks should happen at any given moment.

- Add debugDryRun() method to TownDO that calls reconciler.reconcile()
  and returns actions + metrics without calling applyAction()
- Add POST /debug/towns/:townId/reconcile-dry-run route following the
  same unauthenticated debug pattern as GET /debug/towns/:townId/status
- Response includes actions array, actionsEmitted count, actionsByType
  breakdown, and pendingEventCount

* fix(gastown): drain pending events in debugDryRun() before reconciling

Wrap debugDryRun() in a SQLite savepoint so it can drain and apply
pending town_events (Phase 0) before running reconcile (Phase 1),
matching the real alarm loop behavior. The savepoint is rolled back
in a finally block so the endpoint remains fully side-effect-free.

Adds eventsDrained to the returned metrics.

---------

Co-authored-by: kiloconnect[bot] <240665456+kiloconnect[bot]@users.noreply.github.com>
Co-authored-by: Pedro Heyerdahl <pedro@kilocode.ai>
Co-authored-by: Pedro Heyerdahl <61753986+pedroheyerdahl@users.noreply.github.com>

* feat(gastown): add POST /debug/replay-events endpoint for event replay debugging

Adds debugReplayEvents(from, to) method to Town.do.ts that queries all
town_events in a time range (regardless of processed_at), applies them
to reconstruct state transitions, runs the reconciler, and returns the
computed actions and a state snapshot. Uses a SQLite SAVEPOINT that is
rolled back so the endpoint remains fully side-effect-free.

Route: POST /debug/towns/:townId/replay-events
Body: { from: ISO, to: ISO }
Response: { eventsReplayed, actions, stateSnapshot }

* feat(gastown): emit reconciler metrics to Analytics Engine and add Grafana dashboard panels (#1372)

- Extend writeEvent() to support double3-double10 fields for reconciler metrics
- Emit reconciler_tick event after each alarm tick with all 9 metrics
- Add Reconciler row to Grafana dashboard with 6 panels:
  1. Events drained per tick (timeseries)
  2. Actions emitted per tick by type (stacked bar)
  3. Side effects attempted/succeeded/failed (timeseries)
  4. Invariant violations (stat with >0 alert threshold)
  5. Reconciler wall clock time (timeseries with >500ms threshold)
  6. Pending event queue depth (gauge with >50 threshold)

* fix(gastown): add replay caveat and fix Grafana pending-events gauge query

Add a caveat comment and response field to debugReplayEvents explaining
that events are re-applied on top of live state, not from a pre-window
snapshot — results are approximate, useful for debugging event flow but
not faithful historical reconstruction.

Fix the Grafana 'Pending Event Queue Depth' gauge to show the latest
row's double8 value instead of averaging across the time window.

* feat(gastown): add Sentry capture for reconciler invariant violations

Each invariant violation now triggers Sentry.captureMessage with structured
context (invariant number, message, townId) as both extra data and tags.
Existing analytics event emission is preserved. Added TODO for future
auto-recovery of invariant #7 (working agent with no hook).

---------

Co-authored-by: kiloconnect[bot] <240665456+kiloconnect[bot]@users.noreply.github.com>
Co-authored-by: Pedro Heyerdahl <pedro@kilocode.ai>
Co-authored-by: Pedro Heyerdahl <61753986+pedroheyerdahl@users.noreply.github.com>
@jrf0110
Copy link
Copy Markdown
Contributor Author

jrf0110 commented Apr 6, 2026

Refinery code review passed. All quality gates pass.

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.

1 participant