fix: prevent unsuccessful task from retrying (#1162)

filecoin-project · Mar 16, 2023 · 9f64f34 · 9f64f34
1 parent cbb68c9
commit 9f64f34
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/chain/indexer/distributed/queue/tasks/index.go b/chain/indexer/distributed/queue/tasks/index.go
@@ -103,8 +103,8 @@ func (ih *TipSetTaskHandler) HandleIndexTipSetTask(ctx context.Context, t *asynq
 		return err
 	}
 	if !success {
-		log.Errorw("failed to index task successfully", "taskID", taskID, zap.Inline(p))
-		return fmt.Errorf("indexing tipset.(height) %s.(%d) taskID: %s", p.TipSet.Key(), p.TipSet.Height(), taskID)
+		log.Errorw("failed to index task successfully", "taskID", taskID, "height", p.TipSet.Height(), zap.Inline(p))
+		return nil
 	}
 	log.Infow("index tipset success", "taskID", taskID, zap.Inline(p))
 	return nil