diff --git a/packages/coding-agent/src/telemetry-export.ts b/packages/coding-agent/src/telemetry-export.ts index 43083dc04..0dad0ecc7 100644 --- a/packages/coding-agent/src/telemetry-export.ts +++ b/packages/coding-agent/src/telemetry-export.ts @@ -173,10 +173,10 @@ async function registerProviders(signalConfig: SignalConfig): Promise { const exporter = new OTLPLogExporter(); logProvider = new LoggerProvider({ resource, - processors: [new BatchLogRecordProcessor(exporter)], + processors: [new BatchLogRecordProcessor({ exporter })], }); logs.setGlobalLoggerProvider(logProvider); - otelLogger = logs.getLogger("@oh-my-pi/pi-coding-agent"); + otelLogger = logProvider.getLogger("@oh-my-pi/pi-coding-agent"); unregisterLogSink = logger.registerLogSink(event => { emitOtelLog( event.level, diff --git a/packages/coding-agent/test/otel-signals-probe.ts b/packages/coding-agent/test/otel-signals-probe.ts index 63802c1d7..d9e9d6950 100644 --- a/packages/coding-agent/test/otel-signals-probe.ts +++ b/packages/coding-agent/test/otel-signals-probe.ts @@ -105,7 +105,7 @@ const server = Bun.serve({ port: 0, async fetch(req) { const path = new URL(req.url).pathname; - if (req.method === "POST" && req.headers.get("content-type") === "application/x-protobuf") { + if (req.method === "POST" && req.headers.get("content-type")?.startsWith("application/x-protobuf")) { const body = await req.arrayBuffer(); if (path.endsWith("/v1/metrics")) metricPayloads.push(new Uint8Array(body)); if (body.byteLength > 0) {