diff --git a/test/e2e/virtual/terminatingworkspaces/virtualworkspace_test.go b/test/e2e/virtual/terminatingworkspaces/virtualworkspace_test.go index 90717f14ba4..9dc5fb44a1d 100644 --- a/test/e2e/virtual/terminatingworkspaces/virtualworkspace_test.go +++ b/test/e2e/virtual/terminatingworkspaces/virtualworkspace_test.go @@ -150,8 +150,10 @@ func TestTerminatingWorkspacesVirtualWorkspaceAccess(t *testing.T) { // create workspacetypes for _, wst := range workspaceTypes { - _, err := sourceKcpClusterClient.TenancyV1alpha1().Cluster(wsPath).WorkspaceTypes().Create(ctx, wst, metav1.CreateOptions{}) - require.NoError(t, err) + require.EventuallyWithT(t, func(c *assert.CollectT) { + _, err := sourceKcpClusterClient.TenancyV1alpha1().Cluster(wsPath).WorkspaceTypes().Create(ctx, wst, metav1.CreateOptions{}) + require.NoError(c, err) + }, wait.ForeverTestTimeout, 100*time.Millisecond) source.Artifact(t, func() (runtime.Object, error) { return sourceKcpClusterClient.TenancyV1alpha1().Cluster(wsPath).WorkspaceTypes().Get(ctx, wst.Name, metav1.GetOptions{}) }) @@ -545,8 +547,10 @@ func TestTerminatingWorkspacesVirtualWorkspaceWatch(t *testing.T) { // create workspacetypes for _, wst := range workspaceTypes { - _, err := sourceKcpClusterClient.TenancyV1alpha1().Cluster(wsPath).WorkspaceTypes().Create(ctx, wst, metav1.CreateOptions{}) - require.NoError(t, err) + require.EventuallyWithT(t, func(c *assert.CollectT) { + _, err := sourceKcpClusterClient.TenancyV1alpha1().Cluster(wsPath).WorkspaceTypes().Create(ctx, wst, metav1.CreateOptions{}) + require.NoError(c, err) + }, wait.ForeverTestTimeout, 100*time.Millisecond) source.Artifact(t, func() (runtime.Object, error) { return sourceKcpClusterClient.TenancyV1alpha1().Cluster(wsPath).WorkspaceTypes().Get(ctx, wst.Name, metav1.GetOptions{}) }) @@ -714,8 +718,10 @@ func TestTerminatingWorkspacesVirtualWorkspaceWatchBookmark(t *testing.T) { } // create workspacetypes - _, err = sourceKcpClusterClient.TenancyV1alpha1().Cluster(wsPath).WorkspaceTypes().Create(ctx, wst, metav1.CreateOptions{}) - require.NoError(t, err) + require.EventuallyWithT(t, func(c *assert.CollectT) { + _, err = sourceKcpClusterClient.TenancyV1alpha1().Cluster(wsPath).WorkspaceTypes().Create(ctx, wst, metav1.CreateOptions{}) + require.NoError(c, err) + }, wait.ForeverTestTimeout, 100*time.Millisecond) source.Artifact(t, func() (runtime.Object, error) { return sourceKcpClusterClient.TenancyV1alpha1().Cluster(wsPath).WorkspaceTypes().Get(ctx, wst.Name, metav1.GetOptions{}) })