diff --git a/internal/contentmanager/source/dynamicsource.go b/internal/contentmanager/source/dynamicsource.go index 1f539871f..c7c7b3bd5 100644 --- a/internal/contentmanager/source/dynamicsource.go +++ b/internal/contentmanager/source/dynamicsource.go @@ -139,7 +139,7 @@ func (dis *dynamicInformerSource) Start(ctx context.Context, q workqueue.TypedRa close(dis.syncedChan) }) - _ = wait.PollUntilContextCancel(dis.informerCtx, time.Second, true, func(_ context.Context) (bool, error) { + _ = wait.PollUntilContextCancel(dis.informerCtx, time.Millisecond*100, true, func(_ context.Context) (bool, error) { if sharedIndexInf.HasSynced() { syncOnce() return true, nil diff --git a/internal/contentmanager/source/dynamicsource_test.go b/internal/contentmanager/source/dynamicsource_test.go index 61cbab8ca..ea1d653f3 100644 --- a/internal/contentmanager/source/dynamicsource_test.go +++ b/internal/contentmanager/source/dynamicsource_test.go @@ -7,10 +7,10 @@ import ( "time" "github.com/stretchr/testify/require" - "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/client-go/dynamic/dynamicinformer" dynamicfake "k8s.io/client-go/dynamic/fake" + "k8s.io/client-go/kubernetes/scheme" "sigs.k8s.io/controller-runtime/pkg/handler" "sigs.k8s.io/controller-runtime/pkg/predicate" @@ -92,7 +92,7 @@ func TestDynamicInformerSourceStartAlreadyStarted(t *testing.T) { } func TestDynamicInformerSourceStart(t *testing.T) { - fakeDynamicClient := dynamicfake.NewSimpleDynamicClient(runtime.NewScheme()) + fakeDynamicClient := dynamicfake.NewSimpleDynamicClient(scheme.Scheme) infFact := dynamicinformer.NewDynamicSharedInformerFactory(fakeDynamicClient, time.Minute) dis := NewDynamicSource(DynamicSourceConfig{ DynamicInformerFactory: infFact, @@ -108,5 +108,9 @@ func TestDynamicInformerSourceStart(t *testing.T) { }) require.NoError(t, dis.Start(context.Background(), nil)) + + waitCtx, cancel := context.WithTimeout(context.Background(), 10*time.Second) + defer cancel() + require.NoError(t, dis.WaitForSync(waitCtx)) require.NoError(t, dis.Close()) }