Process ops for repos that failed to backfill (#518)

backfill/gormstore.go

@@ -151,6 +151,14 @@ func (j *Gormjob) BufferOps(ctx context.Context, since *string, rev string, ops
 	case StateInProgress, StateEnqueued:
 		// keep going and buffer the op
 	default:
+		if strings.HasPrefix(j.state, "failed") {
+			if j.retryCount >= MaxRetries {
+				// Process immediately since we're out of retries
+				return false, nil
+			}
+			// Don't buffer the op since it'll get caught in the next retry (hopefully)
+			return true, nil
+		}
 		return false, fmt.Errorf("invalid job state: %q", j.state)
 	}