Lower the log level for context timeouts

find.go

@@ -3,6 +3,7 @@ package main
 import (
 	"bytes"
 	"context"
+	"errors"
 	"fmt"
 	"io"
 	"net/http"
@@ -282,8 +283,13 @@ func (s *server) doFind(ctx context.Context, method, source string, req *url.URL
 		}
 		defer resp.Body.Close()
 		data, err := io.ReadAll(resp.Body)
+
 		if err != nil {
-			log.Warnw("Failed to read backend response", "err", err)
+			if errors.Is(err, context.Canceled) {
+				log.Info("Failed to read backend response because of cancelled context")
+			} else {
+				log.Warnw("Failed to read backend response", "err", err)
+			}
 			return nil, err
 		}
 

find_ndjson.go

@@ -4,6 +4,7 @@ import (
 	"bufio"
 	"context"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"hash/crc32"
 	"io"
@@ -242,7 +243,12 @@ func (s *server) doFindNDJson(ctx context.Context, w http.ResponseWriter, source
 					continue
 				}
 				if err := scanner.Err(); err != nil {
-					log.Warnw("Failed to read backend response", "err", err)
+					if errors.Is(err, context.Canceled) {
+						log.Info("Failed to read backend response because of cancelled context")
+					} else {
+						log.Warnw("Failed to read backend response", "err", err)
+					}
+
 					return nil, circuitbreaker.MarkAsSuccess(err)
 				}
 				return nil, nil

scatter_gather.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"context"
+	"errors"
 	"sync"
 	"time"
 )
@@ -41,7 +42,11 @@ func (sg *scatterGather[B, R]) scatter(ctx context.Context, forEach func(context
 				err = target.CB().Done(cctx, err)
 			}
 			if err != nil {
-				log.Errorw("failed to scatter on target", "target", target.URL().Host, "err", err, "maxWait", sg.maxWait)
+				if errors.Is(err, context.DeadlineExceeded) {
+					log.Infow("failed to scatter on target because context deadline exceeded", "target", target.URL().Host, "maxWait", sg.maxWait)
+				} else {
+					log.Errorw("failed to scatter on target", "target", target.URL().Host, "err", err, "maxWait", sg.maxWait)
+				}
 				return
 			}
 			if sout != nil {