From e963855f6fea1e12a22589b621c82b6e7e7e9ce8 Mon Sep 17 00:00:00 2001
From: pippellia-btc <pippellia@gmail.com>
Date: Tue, 17 Jun 2025 12:23:25 +0200
Subject: [PATCH] avoid print err for ctx cancellation at shutdown

---
 pkg/pipe/arbiter.go | 4 ++--
 pkg/pipe/engine.go  | 4 ++--
 pkg/pipe/intake.go  | 4 ++--
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/pkg/pipe/arbiter.go b/pkg/pipe/arbiter.go
index 2e97800..62ecba5 100644
--- a/pkg/pipe/arbiter.go
+++ b/pkg/pipe/arbiter.go
@@ -65,7 +65,7 @@ func Arbiter(ctx context.Context, config ArbiterConfig, db redb.RedisDB, send fu
 
 		case <-ticker.C:
 			total, err := db.TotalWalks(ctx)
-			if err != nil {
+			if err != nil && ctx.Err() == nil {
 				log.Printf("Arbiter: %v", err)
 				continue
 			}
@@ -75,7 +75,7 @@ func Arbiter(ctx context.Context, config ArbiterConfig, db redb.RedisDB, send fu
 
 			if changeRatio > config.Activation {
 				promoted, demoted, err := arbiterScan(ctx, config, db, send)
-				if err != nil {
+				if err != nil && ctx.Err() == nil {
 					log.Printf("Arbiter: %v", err)
 				}
 
diff --git a/pkg/pipe/engine.go b/pkg/pipe/engine.go
index eb09cb8..0523640 100644
--- a/pkg/pipe/engine.go
+++ b/pkg/pipe/engine.go
@@ -113,7 +113,7 @@ func Archiver(
 				}
 			}()
 
-			if err != nil {
+			if err != nil && ctx.Err() == nil {
 				log.Printf("Archiver: event ID %s, kind %d by %s: %v", event.ID, event.Kind, event.PubKey, err)
 			}
 
@@ -170,7 +170,7 @@ func GraphBuilder(
 				return cache.Update(opctx, delta)
 			}()
 
-			if err != nil {
+			if err != nil && ctx.Err() == nil {
 				log.Printf("GraphBuilder: event ID %s, kind %d by %s: %v", event.ID, event.Kind, event.PubKey, err)
 			}
 
diff --git a/pkg/pipe/intake.go b/pkg/pipe/intake.go
index b973a83..17dfe48 100644
--- a/pkg/pipe/intake.go
+++ b/pkg/pipe/intake.go
@@ -186,7 +186,7 @@ func Fetcher(ctx context.Context, config FetcherConfig, pubkeys <-chan string, s
 			}
 
 			events, err := fetch(ctx, pool, config.Relays, batch)
-			if err != nil {
+			if err != nil && ctx.Err() == nil {
 				log.Printf("Fetcher: %v", err)
 				continue
 			}
@@ -202,7 +202,7 @@ func Fetcher(ctx context.Context, config FetcherConfig, pubkeys <-chan string, s
 
 		case <-timer:
 			events, err := fetch(ctx, pool, config.Relays, batch)
-			if err != nil {
+			if err != nil && ctx.Err() == nil {
 				log.Printf("Fetcher: %v", err)
 				continue
 			}