()
| 141 | // survive request termination. |
| 142 | export const installTracerProvider = (): boolean => ensureGlobalTracerProvider(); |
| 143 | export const flushTracerProvider = async (): Promise<void> => { |
| 144 | if (!provider) return; |
| 145 | const startedAt = Date.now(); |
| 146 | // oxlint-disable-next-line executor/no-try-catch-or-throw -- observability boundary; preserve forceFlush failure behavior while counting it |
| 147 | try { |
| 148 | await provider.forceFlush(); |
| 149 | recordForceFlush(Date.now() - startedAt, false); |
| 150 | } catch (error) { |
| 151 | recordForceFlush(Date.now() - startedAt, true); |
| 152 | // oxlint-disable-next-line executor/no-try-catch-or-throw -- preserve original rejection for waitUntil diagnostics |
| 153 | throw error; |
| 154 | } |
| 155 | }; |
| 156 | |
| 157 | const makeTelemetryLive = (): Layer.Layer<never> => |
| 158 | Layer.mergeAll( |
no test coverage detected