| Index: logdog/server/cmd/logdog_collector/main.go
|
| diff --git a/logdog/server/cmd/logdog_collector/main.go b/logdog/server/cmd/logdog_collector/main.go
|
| index 078a9de979c742dc35bd487bb7bfa4042f657f2e..1a67d151190a41f05bde78b60d7aae7ed2cc9e11 100644
|
| --- a/logdog/server/cmd/logdog_collector/main.go
|
| +++ b/logdog/server/cmd/logdog_collector/main.go
|
| @@ -191,7 +191,7 @@ func (a *application) processMessage(c context.Context, coll *collector.Collecto
|
| tsTaskProcessingTime.Add(c, duration.Seconds()*1000)
|
|
|
| switch {
|
| - case errors.IsTransient(err):
|
| + case retry.Tag.In(err):
|
| // Do not consume
|
| log.Fields{
|
| log.ErrorKey: err,
|
|
|