Skip to content

feat(stovepipe): record accepted request state - #658

Open
mnoah1 wants to merge 2 commits into
mnoah1/stovepipe-request-history-recorderfrom
mnoah1/stovepipe-request-history-accepted
Open

feat(stovepipe): record accepted request state#658
mnoah1 wants to merge 2 commits into
mnoah1/stovepipe-request-history-recorderfrom
mnoah1/stovepipe-request-history-accepted

Conversation

@mnoah1

@mnoah1 mnoah1 commented Sep 1, 2026

Copy link
Copy Markdown
Contributor

Summary

Intent:

  • Establish every newly admitted request initial accepted-state log before dependent processing begins.
  • Make an Ingest retry repair a missing accepted entry before republishing work.

Changes:

  • Construct the accepted-state log with NewRequestStateLog and persist it through Materializer.PersistLog.
  • Pass the queue-scoped storage aggregate so future summary projections remain internal to the materializer.
  • Stop queue-pointer advancement and process publication when materialization fails.
  • Wire one materializer instance into Ingest and cover new, duplicate, repair, and failure paths.

This PR builds on #657, which introduces the request log materializer.

Test Plan

  • bazel test //stovepipe/controller:go_default_test //service/stovepipe/server:go_default_test --cache_test_results=no
  • make check-gazelle
  • make lint

Revert Plan

  • Revert this PR to stop writing accepted-state logs from Ingest while retaining the materializer for later callers.

Issues

Stack

  1. feat(stovepipe): add request log materializer #657
  2. @ feat(stovepipe): record accepted request state #658

@mnoah1
mnoah1 force-pushed the mnoah1/stovepipe-request-history-accepted branch 3 times, most recently from 9b04367 to e441df5 Compare September 1, 2026 17:24
Summary:
Intent:
- Establish every newly admitted request's initial history before dependent processing begins.
- Make an Ingest retry repair a missing accepted entry before republishing work.

Changes:
- Record the durable accepted request through the queue-scoped request log store.
- Stop queue-pointer advancement and process publication when recording fails.
- Wire one recorder instance into Ingest and cover new, duplicate, repair, and failure paths.

This PR builds on #657, which introduces the request state log recorder.

---

<sub>Generated by the 🪄 [pr-create](https://sg.uberinternal.com/code.uber.internal/uber-code/devexp-agent-marketplace/-/blob/claude-code/plugins/dev/uber-dev/skills/pr-create/SKILL.md) skill in devexp-agent-marketplace</sub>
@mnoah1
mnoah1 force-pushed the mnoah1/stovepipe-request-history-accepted branch from e441df5 to c3257ba Compare September 1, 2026 17:35
@mnoah1
mnoah1 marked this pull request as ready for review September 1, 2026 20:48
@mnoah1
mnoah1 requested review from a team, behinddwalls and sbalabanov as code owners September 1, 2026 20:48
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