Index: tumble/process.go |
diff --git a/tumble/process.go b/tumble/process.go |
index afc8907f0dbf4effcccae455b3ab15292d2da02c..dde479d44be6394f87cad1bb85ee148e562624ef 100644 |
--- a/tumble/process.go |
+++ b/tumble/process.go |
@@ -16,6 +16,7 @@ import ( |
"github.com/luci/luci-go/common/data/stringset" |
"github.com/luci/luci-go/common/errors" |
"github.com/luci/luci-go/common/logging" |
+ "github.com/luci/luci-go/common/retry/transient" |
"github.com/luci/luci-go/common/sync/parallel" |
"github.com/luci/gae/filter/txnBuf" |
@@ -233,7 +234,7 @@ func (t *processTask) process(c context.Context, cfg *Config, q *ds.Query) error |
numProcessed, errCount, transientErrCount) |
switch { |
case transientErrCount > 0: |
- return errors.WrapTransient(errors.New("transient error during shard processing")) |
+ return errors.New("transient error during shard processing", transient.Tag) |
case errCount > 0: |
return errors.New("encountered non-transient error during shard processing") |
} |