analyer/aggregate_stats: fix errors check

oasisprotocol · Dec 9, 2024 · 19702fa · 19702fa
1 parent ca4ef6d
commit 19702fa
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/.changelog/822.trivial.md b/.changelog/822.trivial.md
diff --git a/analyzer/aggregate_stats/aggregate_stats.go b/analyzer/aggregate_stats/aggregate_stats.go
@@ -206,14 +206,14 @@ func (a *aggregateStatsAnalyzer) aggregateStatsWorker(ctx context.Context) {
 			switch {
 			case err == nil:
 				// Continues below.
-			case errors.Is(pgx.ErrNoRows, err):
+			case errors.Is(err, pgx.ErrNoRows):
 				// No stats yet. Start at the earliest indexed block.
 				var earliestBlockTs *time.Time
 				earliestBlockTs, err = a.earliestBlockTs(statCtx, statsComputation.layer)
 				switch {
 				case err == nil:
 					latestComputed = floorWindow(earliestBlockTs)
-				case errors.Is(pgx.ErrNoRows, err):
+				case errors.Is(err, pgx.ErrNoRows):
 					// No data log a debug only log.
 					logger.Debug("no stats available yet, skipping iteration")
 					cancel()
@@ -234,7 +234,7 @@ func (a *aggregateStatsAnalyzer) aggregateStatsWorker(ctx context.Context) {
 			switch {
 			case err == nil:
 				// Continues below.
-			case errors.Is(pgx.ErrNoRows, err):
+			case errors.Is(err, pgx.ErrNoRows):
 				logger.Debug("no stats available yet, skipping iteration")
 				cancel()
 				continue