diff --git a/pkg/logstructured/logstructured.go b/pkg/logstructured/logstructured.go
index 982bcbcd..f93beb0b 100644
--- a/pkg/logstructured/logstructured.go
+++ b/pkg/logstructured/logstructured.go
@@ -2,6 +2,7 @@ package logstructured
 
 import (
 	"context"
+	"errors"
 	"sync"
 	"time"
 
@@ -446,7 +447,9 @@ func (l *LogStructured) Watch(ctx context.Context, prefix string, revision int64
 
 	rev, kvs, err := l.log.After(ctx, prefix, revision, 0)
 	if err != nil {
-		logrus.Errorf("Failed to list %s for revision %d: %v", prefix, revision, err)
+		if !errors.Is(err, context.Canceled) {
+			logrus.Errorf("Failed to list %s for revision %d: %v", prefix, revision, err)
+		}
 		if err == server.ErrCompacted {
 			compact, _ := l.log.CompactRevision(ctx)
 			wr.CompactRevision = compact