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

vitorsavian · vitorsavian · commit 62fa77a820f6 · 2024-03-26T10:52:08.000-03:00
Signed-off-by: Vitor Savian &lt;vitor.savian@suse.com&gt;
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
 		}
 

Original file line number	Diff line number	Diff line change
`@@ -432,7 +432,9 @@ func (s *SQLLog) poll(result chan interface{}, pollStart int64) {`
`432`	`432`
`433`	`433`	`rows, err := s.d.After(s.ctx, "%", s.currentRev, pollBatchSize)`
`434`	`434`	`if err != nil {`
`435`		`- logrus.Errorf("fail to list latest changes: %v", err)`
	`435`	`+ if !errors.Is(err, context.Canceled) {`
	`436`	`+ logrus.Errorf("fail to list latest changes: %v", err)`
	`437`	`+ }`
`436`	`438`	`continue`
`437`	`439`	`}`
`438`	`440`