From a8be062721b3daaa9571315b636a2cd7d036fbd4 Mon Sep 17 00:00:00 2001 From: nyagamunene Date: Mon, 6 May 2024 13:02:04 +0300 Subject: [PATCH] Changed from error to errorcontext in redis handle Signed-off-by: nyagamunene --- pkg/events/redis/subscriber.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/events/redis/subscriber.go b/pkg/events/redis/subscriber.go index 910ecca3489..925589c77ee 100644 --- a/pkg/events/redis/subscriber.go +++ b/pkg/events/redis/subscriber.go @@ -103,13 +103,13 @@ func (es *subEventStore) handle(ctx context.Context, stream string, msgs []redis } if err := h.Handle(ctx, event); err != nil { - es.logger.Warn(fmt.Sprintf("failed to handle redis event: %s", err)) + es.logger.ErrorContext(ctx, fmt.Sprintf("failed to handle redis event: %s", err)) return } if err := es.client.XAck(ctx, stream, group, msg.ID).Err(); err != nil { - es.logger.Warn(fmt.Sprintf("failed to ack redis event: %s", err)) + es.logger.ErrorContext(ctx, fmt.Sprintf("failed to ack redis event: %s", err)) return }