Changed from error to errorcontext in redis handle

Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>
absmach · May 15, 2024 · a8be062 · a8be062
1 parent bb4f0b5
commit a8be062
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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
 		}