From 8c3f93b601e14dace05aa0ea113bb68d3c9f6b51 Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Mon, 16 Feb 2026 18:57:44 -0600 Subject: [PATCH] update tracer name for processor --- internal/route/route.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/route/route.go b/internal/route/route.go index d59a6c8..5881b9d 100644 --- a/internal/route/route.go +++ b/internal/route/route.go @@ -81,7 +81,7 @@ func (r *ProcessorRoute) ProcessPayload(ctx context.Context, payload any) (any, processCtx, processSpan := tracer.Start(ctx, "ProcessPayload") defer processSpan.End() for processorIndex, processor := range r.processors { - processorCtx, processorSpan := tracer.Start(processCtx, "processor.process", trace.WithAttributes(attribute.Int("processor.index", processorIndex), attribute.String("processor.type", processor.Type()))) + processorCtx, processorSpan := otel.Tracer("processor").Start(processCtx, "process", trace.WithAttributes(attribute.Int("processor.index", processorIndex), attribute.String("processor.type", processor.Type()))) processedPayload, err := processor.Process(processorCtx, payload) if err != nil { processorSpan.SetStatus(codes.Error, "route processor error")