fix: canceled should always be set totrue when cancel a watch request

Signed-off-by: Nic <[email protected]>
k3s-io · Dec 4, 2024 · 73df6c7 · 73df6c7
1 parent 59c88f9
commit 73df6c7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/server/watch.go b/pkg/server/watch.go
@@ -219,7 +219,7 @@ func (w *watcher) Cancel(watchID, revision, compactRev int64, err error) {
 
 	serr := w.server.Send(&etcdserverpb.WatchResponse{
 		Header:          txnHeader(revision),
-		Canceled:        err != nil,
+		Canceled:        true,
 		CancelReason:    reason,
 		WatchId:         watchID,
 		CompactRevision: compactRev,