You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Adds two counters to the native realtime backend so we can see how much duplicate row serialization the change router does per batch. When a run changes it can match several held feeds at once (a run subscription plus one or more tag/list feeds), and today each matching feed serializes that run's wire value independently. These counters quantify that fan-out so we can decide whether a shared serialization step is worth it.
What they measure
realtime_native.emission_run_serializations: total wire-value serializations performed across feeds per batch (what the current path does).
realtime_native.emission_distinct_serializations: distinct (columns, run) rows those serializations cover (what a serialize-once-per-batch step would do).
Average feeds-per-run is run_serializations / distinct_serializations, and 1 - distinct / run_serializations is the serialization work a shared step could save. Wired through a new optional onEmissionFanout callback on the router. No behavior change.
Merging this PR will not cause a version bump for any packages. If these changes should not result in a new version, you're good to go. If these changes should result in a version bump, you need to add a changeset.
This PR includes no changesets
When changesets are added to this PR, you'll see the packages that this PR includes changesets for and the associated semver types
Adds per-batch realtime emission fanout statistics to EnvChangeRouter, including total feed row deliveries and distinct (columnSig, runId) serializations. The native realtime client exposes Prometheus counters and records these values through the router callback. A changelog entry documents the new metrics.
🚥 Pre-merge checks | ✅ 4 | ❌ 1
❌ Failed checks (1 warning)
Check name
Status
Explanation
Resolution
Description check
⚠️ Warning
The description misses required template sections like Closes #, checklist, testing, changelog, and screenshots.
Add the missing template sections, including issue link, checklist items, testing steps, changelog entry, and screenshots or N/A.
✅ Passed checks (4 passed)
Check name
Status
Explanation
Docstring Coverage
✅ Passed
No functions found in the changed files to evaluate docstring coverage. Skipping docstring coverage check.
Linked Issues check
✅ Passed
Check skipped because no linked issues were found for this pull request.
Out of Scope Changes check
✅ Passed
Check skipped because no linked issues were found for this pull request.
Title check
✅ Passed
The title clearly summarizes the main change: adding emission fan-out metrics to the native realtime feed.
✨ Finishing Touches📝 Generate docstrings
Create stacked PR
Commit on current branch
🧪 Generate unit tests (beta)
Create PR with unit tests
Commit unit tests in branch perf/realtime-serialize-hotpath
Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
Adds two counters to the native realtime backend so we can see how much duplicate row serialization the change router does per batch. When a run changes it can match several held feeds at once (a run subscription plus one or more tag/list feeds), and today each matching feed serializes that run's wire value independently. These counters quantify that fan-out so we can decide whether a shared serialization step is worth it.
What they measure
realtime_native.emission_run_serializations: total wire-value serializations performed across feeds per batch (what the current path does).realtime_native.emission_distinct_serializations: distinct (columns, run) rows those serializations cover (what a serialize-once-per-batch step would do).Average feeds-per-run is
run_serializations / distinct_serializations, and1 - distinct / run_serializationsis the serialization work a shared step could save. Wired through a new optionalonEmissionFanoutcallback on the router. No behavior change.