improve error handling

filecoin-project · Sep 18, 2024 · 11712bf · 11712bf
1 parent 05b84ec
commit 11712bf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/chain/index/api.go b/chain/index/api.go
@@ -16,11 +16,11 @@ func (si *SqliteIndexer) sanityCheckBackfillEpoch(ctx context.Context, epoch abi
 	// should be less than the max non reverted height in the Index
 	var maxNonRevertedHeight sql.NullInt64
 	err := si.stmts.getMaxNonRevertedHeightStmt.QueryRowContext(ctx).Scan(&maxNonRevertedHeight)
-	if err != nil {
+	if err != nil && err != sql.ErrNoRows {
 		return xerrors.Errorf("failed to get max non reverted height: %w", err)
 	}
 	// couldn't find any non-reverted entries
-	if !maxNonRevertedHeight.Valid {
+	if err == sql.ErrNoRows || !maxNonRevertedHeight.Valid {
 		return nil
 	}
 	if epoch >= abi.ChainEpoch(maxNonRevertedHeight.Int64) {