Skip to content

Commit

Permalink
Dropping item is not an error, logging as a warrning
Browse files Browse the repository at this point in the history
  • Loading branch information
lukaszo committed Mar 21, 2024
1 parent a64296f commit 6967292
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -258,7 +258,7 @@ func (w *worker) Run(ctx context.Context) {
if itm.maxTries != 0 && itm.tryCount == itm.maxTries {
parentSpan.SetStatus(codes.Error, "Max try exceeded")
parentSpan.End()
l.Error("Max retry exceeded, dropping item", "object_id", itm.id)
l.Warn("Max retry exceeded, dropping item", "object_id", itm.id)
w.metrics.handleResult.Add(ctx, 1, metric.WithAttributes(attrWorkerId(w.id), attribute.String("result", "drop_max_tries")))
} else {
if res.Error != nil {
Expand Down

0 comments on commit 6967292

Please sign in to comment.