diff --git a/src/Contracts/Masa.Scheduler.Contracts.Server/Infrastructure/Utils/HttpUtils.cs b/src/Contracts/Masa.Scheduler.Contracts.Server/Infrastructure/Utils/HttpUtils.cs index 07bcea9..6f37b5d 100644 --- a/src/Contracts/Masa.Scheduler.Contracts.Server/Infrastructure/Utils/HttpUtils.cs +++ b/src/Contracts/Masa.Scheduler.Contracts.Server/Infrastructure/Utils/HttpUtils.cs @@ -5,7 +5,7 @@ namespace Masa.Scheduler.Contracts.Server.Infrastructure.Utils; public static class HttpUtils { - private static ActivitySource _source = new ActivitySource("Masa.Scheduler.Background"); + public static ActivitySource ActivitySource { get; private set; } = new ActivitySource("Masa.Scheduler.Background"); public static HttpMethod ConvertHttpMethod(HttpMethods methods) { @@ -36,7 +36,7 @@ public static void AddHttpHeader(HttpClient client, List> httpParameters) diff --git a/src/Services/Masa.Scheduler.Services.Worker/Extensions/OpenTelemetrySchedulerExtensions.cs b/src/Services/Masa.Scheduler.Services.Worker/Extensions/OpenTelemetrySchedulerExtensions.cs index 71f0e7b..023fa09 100644 --- a/src/Services/Masa.Scheduler.Services.Worker/Extensions/OpenTelemetrySchedulerExtensions.cs +++ b/src/Services/Masa.Scheduler.Services.Worker/Extensions/OpenTelemetrySchedulerExtensions.cs @@ -46,7 +46,7 @@ public static IServiceCollection AddSchedulerObservable(this IServiceCollection { builder.SetResourceBuilder(resources); builder.AddOtlpExporter(options => options.Endpoint = uri); - builder.AddSource("Masa.Scheduler.Background"); + builder.AddSource(HttpUtils.ActivitySource.Name); }, builder => {