Add a error verification when failed list error is from context canceled

Signed-off-by: Vitor Savian <[email protected]>
k3s-io · Mar 26, 2024 · 62fa77a · 62fa77a
1 parent 774b2e8
commit 62fa77a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/logstructured/sqllog/sql.go b/pkg/logstructured/sqllog/sql.go
@@ -432,7 +432,9 @@ func (s *SQLLog) poll(result chan interface{}, pollStart int64) {
 
 		rows, err := s.d.After(s.ctx, "%", s.currentRev, pollBatchSize)
 		if err != nil {
-			logrus.Errorf("fail to list latest changes: %v", err)
+			if !errors.Is(err, context.Canceled) {
+				logrus.Errorf("fail to list latest changes: %v", err)
+			}
 			continue
 		}