From 438c396aeb2d33966def705898fcbfd3c27c039c Mon Sep 17 00:00:00 2001 From: Joel Wetzell Date: Tue, 26 May 2026 17:53:34 -0500 Subject: [PATCH] include processor index in processpayload error --- internal/route/route.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/route/route.go b/internal/route/route.go index aa5df54..98cf55b 100644 --- a/internal/route/route.go +++ b/internal/route/route.go @@ -40,12 +40,12 @@ func (r *Route) Input() string { } func (r *Route) ProcessPayload(ctx context.Context, wrappedPayload common.WrappedPayload) (any, error) { - for _, processor := range r.processors { + for processorIndex, processor := range r.processors { processedPayload, err := processor.Process(ctx, wrappedPayload) if err != nil { - return nil, err + return nil, fmt.Errorf("processor[%d] error: %w", processorIndex, err) } - //NOTE(jwetzell) payload has been marked as an end + //NOTE(jwetzell) payload has been marked as an end without error if processedPayload.End { return processedPayload.Payload, nil }