ext/hyperframes
2
0
Fork 0
mirror of https://github.com/heygen-com/hyperframes.git synced 2026-09-03 12:54:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(producer): emit eligible_off cohort-sizing signal when parallel-stream router is off

Browse Source
This commit is contained in:
vanceingalls
2026-07-11 22:38:04 +00:00
parent 88c21ccd8b
commit 591235f05c
4 changed files with 29 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/cli/src/telemetry/events.ts
+2 -1
View File
@@ -53,7 +53,8 @@ export interface RenderObservabilityTelemetryPayload {
captureDePreRouterWorkers?: number;
captureDeSelfVerifyFallback?: boolean;
captureDeFallbackReason?: string;
/** Non-DE parallel-streaming router outcome ("screenshot" | "beginframe"). */
/** Non-DE parallel-streaming router outcome ("screenshot" | "beginframe" —
* routed; "eligible_off" — would route but the kill switch is off). */
captureParallelStream?: string;
observabilityExtractVideoCount?: number;
observabilityExtractedVideoCount?: number;
packages/cli/src/telemetry/renderObservability.test.ts
+7
View File
@@ -91,6 +91,13 @@ describe("renderObservabilityTelemetryPayload — non-DE parallel-stream router"
expect(payload.captureParallelStream).toBe("beginframe");
});
it("maps the passive eligible_off cohort-sizing signal", () => {
const payload = renderObservabilityTelemetryPayload(
makeSummary({ captureParallelStream: "eligible_off" }),
);
expect(payload.captureParallelStream).toBe("eligible_off");
});
it("stays undefined when the router never fired", () => {
const payload = renderObservabilityTelemetryPayload(makeSummary({}));
expect(payload.captureParallelStream).toBeUndefined();