diff --git a/staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go b/staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
index 9267722cf8a..01af44118a9 100644
--- a/staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
+++ b/staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
@@ -141,7 +141,10 @@ func TestWatchContextCancel(t *testing.T) {
 	cancel()
 	// When we watch with a canceled context, we should detect that it's context canceled.
 	// We won't take it as error and also close the watcher.
-	w, err := store.watcher.Watch(canceledCtx, "/abc", 0, false, false, storage.Everything)
+	w, err := store.Watch(canceledCtx, "/abc", storage.ListOptions{
+		ResourceVersion:      "0",
+		Predicate:            storage.Everything,
+	})
 	if err != nil {
 		t.Fatal(err)
 	}