From 6b0ebedccc19f3fbf877487cffa34c3694d0c275 Mon Sep 17 00:00:00 2001 From: Jordan Liggitt Date: Thu, 27 Mar 2025 11:54:39 -0400 Subject: [PATCH] Set non-experimental WatchProgressNotifyInterval config field --- .../src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 f31afd89cf0..77b0cfcd819 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 @@ -105,7 +105,7 @@ func TestWatchInitializationSignal(t *testing.T) { func TestProgressNotify(t *testing.T) { clusterConfig := testserver.NewTestConfig(t) - clusterConfig.ExperimentalWatchProgressNotifyInterval = time.Second + clusterConfig.WatchProgressNotifyInterval = time.Second ctx, store, _ := testSetup(t, withClientConfig(clusterConfig)) storagetesting.RunOptionalTestProgressNotify(ctx, t, store) @@ -122,7 +122,7 @@ func TestWatchWithUnsafeDelete(t *testing.T) { // etcd implementation doesn't have any effect. func TestWatchDispatchBookmarkEvents(t *testing.T) { clusterConfig := testserver.NewTestConfig(t) - clusterConfig.ExperimentalWatchProgressNotifyInterval = time.Second + clusterConfig.WatchProgressNotifyInterval = time.Second ctx, store, _ := testSetup(t, withClientConfig(clusterConfig)) storagetesting.RunTestWatchDispatchBookmarkEvents(ctx, t, store, false)