diff --git a/apps/webapp/app/services/runsReplicationInstance.server.ts b/apps/webapp/app/services/runsReplicationInstance.server.ts index ad27724410..e956c2b93d 100644 --- a/apps/webapp/app/services/runsReplicationInstance.server.ts +++ b/apps/webapp/app/services/runsReplicationInstance.server.ts @@ -1,10 +1,10 @@ import { ClickHouse } from "@internal/clickhouse"; -import { RunsReplicationService } from "./runsReplicationService.server"; -import { singleton } from "~/utils/singleton"; import invariant from "tiny-invariant"; import { env } from "~/env.server"; -import { metricsRegister } from "~/metrics.server"; +import { singleton } from "~/utils/singleton"; +import { provider } from "~/v3/tracer.server"; import { logger } from "./logger.server"; +import { RunsReplicationService } from "./runsReplicationService.server"; export const runsReplicationInstance = singleton( "runsReplicationInstance", @@ -49,6 +49,7 @@ function initializeRunsReplicationInstance() { leaderLockRetryIntervalMs: env.RUN_REPLICATION_LEADER_LOCK_RETRY_INTERVAL_MS, ackIntervalSeconds: env.RUN_REPLICATION_ACK_INTERVAL_SECONDS, logLevel: env.RUN_REPLICATION_LOG_LEVEL, + tracer: provider.getTracer("runs-replication-service"), }); if (env.RUN_REPLICATION_ENABLED === "1") { diff --git a/apps/webapp/app/v3/tracer.server.ts b/apps/webapp/app/v3/tracer.server.ts index c40773cdd9..fc676eb424 100644 --- a/apps/webapp/app/v3/tracer.server.ts +++ b/apps/webapp/app/v3/tracer.server.ts @@ -83,7 +83,7 @@ class CustomWebappSampler implements Sampler { } } -export const { tracer, logger: otelLogger } = singleton("tracer", getTracer); +export const { tracer, logger: otelLogger, provider } = singleton("tracer", getTracer); export async function startActiveSpan( name: string, @@ -155,6 +155,7 @@ function getTracer() { return { tracer: trace.getTracer("trigger.dev", "3.3.12"), logger: logs.getLogger("trigger.dev", "3.3.12"), + provider: new NodeTracerProvider(), }; } @@ -260,6 +261,7 @@ function getTracer() { return { tracer: provider.getTracer("trigger.dev", "3.3.12"), logger: logs.getLogger("trigger.dev", "3.3.12"), + provider, }; }