internal sealed class FilteringProcessor : BaseProcessor<Activity>
{
    private static bool HasParent(Activity activity, Func<Activity, bool> condition)
    {
        Activity? current = activity;

        while (current != null)
        {
            if (condition(current))
            {
                return true;
            }
            current = current.Parent;
        }

        return false;
    }

    // Called when an activity ends
    // Filters out activities that are not coming from ASP.NET Core request, MassTransit or Hangfire job
    public override void OnEnd(Activity activity)
    {
        var activityKinds = new ActivityKind[] { ActivityKind.Server, ActivityKind.Consumer };

        // If the activity does not have a parent that matches the specified kinds or tags, mark it as not recorded
        if (!HasParent(activity, a =>
            activityKinds.Any(y => a.Kind == y)
            || a.Tags.Any(y => y.Key == "job.id")))
        {
            Console.WriteLine($"Filtering out activity: {activity.OperationName} {activity.DisplayName}");
            activity.ActivityTraceFlags &= ~ActivityTraceFlags.Recorded;
            activity.IsAllDataRequested = false;
        }
    }
}

 services.AddOpenTelemetry()
     .ConfigureResource(resource => resource
         .AddService(serviceName: ctx.HostingEnvironment.ApplicationName, serviceVersion: ServiceVersion.FromTypeAssembly<TStartup>())
         .AddHostDetector()
         )
     .WithTracing(tracerProviderBuilder =>
         tracerProviderBuilder
             .AddAspNetCoreInstrumentation(o =>
             {
                 // filter out health checks
                 o.Filter = (httpContext) => !httpContext.Request.Path.ToString().Contains(".probe", StringComparison.InvariantCultureIgnoreCase);
                 o.RecordException = true;
             }) // <-- Adds ASP.NET Core telemetry sources
             .AddHttpClientInstrumentation(
                 // https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/core/Azure.Core/samples/Diagnostics.md#filtering-out-duplicated-http-client-activities
                 o =>
                 {
                     o.FilterHttpRequestMessage = (_) => Activity.Current?.Parent?.Source?.Name != "Azure.Core.Http";
                     o.RecordException = true;
                 }) // <-- Adds HttpClient telemetry sources
             .AddSqlClientInstrumentation(o =>
             {
                 o.SetDbStatementForText = true;
                 o.RecordException = true;
             }) // <-- Adds SQL Client telemetry sources
             .AddHangfireInstrumentation(o =>
             {
                 o.RecordException = true;
             }) // https://github.com/open-telemetry/opentelemetry-dotnet-contrib/tree/main/src/OpenTelemetry.Instrumentation.Hangfire
             .AddSource("Azure.*") // <-- Adds Azure telemetry sources https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/core/Azure.Core/samples/Diagnostics.md#opentelemetry-configuration
             .AddSource(MassTransit.Logging.DiagnosticHeaders.DefaultListenerName) // https://masstransit.io/documentation/configuration/observability#aspnet-core-application


             .AddProcessor(new FilteringProcessor()) // <-- Adds a processor to filter out unwanted activities
             .AddSentry() // <-- Configure OpenTelemetry to send trace information to Sentry
     );