Merge pull request #822 from oasisprotocol/ptrus/feature/trivial-erro…

…rs-check analyer/aggregate_stats: fix errors check
oasisprotocol · Dec 10, 2024 · 2225e3f · 2225e3f
2 parents ca4ef6d + 19702fa
commit 2225e3f
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