this repo has no description
Process ops for repos that failed to backfill (#518)
+8
+8
backfill/gormstore.go
+8
backfill/gormstore.go
···
151
151
case StateInProgress, StateEnqueued:
152
152
// keep going and buffer the op
153
153
default:
154
+
if strings.HasPrefix(j.state, "failed") {
155
+
if j.retryCount >= MaxRetries {
156
+
// Process immediately since we're out of retries
157
+
return false, nil
158
+
}
159
+
// Don't buffer the op since it'll get caught in the next retry (hopefully)
160
+
return true, nil
161
+
}
154
162
return false, fmt.Errorf("invalid job state: %q", j.state)
155
163
}
156
164