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

Function flushTracerProvider

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

Source from the content-addressed store, hash-verified

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

Callers 3

traceCloudMcpRequestFunction · 0.90
server.tsFile · 0.90
flushTelemetryMethod · 0.90

Calls 2

recordForceFlushFunction · 0.90
forceFlushMethod · 0.45

Tested by

no test coverage detected