MCPcopy Create free account
hub / github.com/UsefulSoftwareCo/executor / flushTracerProvider

Function flushTracerProvider

apps/cloud/src/observability/telemetry.ts:112–124  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

110// survive request termination.
111export const installTracerProvider = (): boolean => ensureGlobalTracerProvider();
112export const flushTracerProvider = async (): Promise<void> => {
113 if (!provider) return;
114 const startedAt = Date.now();
115 // oxlint-disable-next-line executor/no-try-catch-or-throw -- observability boundary; preserve forceFlush failure behavior while counting it
116 try {
117 await provider.forceFlush();
118 recordForceFlush(Date.now() - startedAt, false);
119 } catch (error) {
120 recordForceFlush(Date.now() - startedAt, true);
121 // oxlint-disable-next-line executor/no-try-catch-or-throw -- preserve original rejection for waitUntil diagnostics
122 throw error;
123 }
124};
125
126const makeTelemetryLive = (): Layer.Layer<never> =>
127 Layer.unwrap(

Callers 2

server.tsFile · 0.90
flushTelemetryMethod · 0.90

Calls 2

recordForceFlushFunction · 0.90
forceFlushMethod · 0.45

Tested by

no test coverage detected