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

Signed-off-by: Vitor Savian <vitor.savian@suse.com>
k3s-io · Mar 19, 2024 · 4b9c8c9 · 4b9c8c9
1 parent 5c1e58f
commit 4b9c8c9
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
 		}