avoid print err for ctx cancellation at shutdown

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)
 				}
 

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)
 			}
 

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
 			}