From 9760867deeea5e974f122e392c7ef0e2dfa24f79 Mon Sep 17 00:00:00 2001 From: "Nelo-T. Wallus" Date: Fri, 20 Mar 2026 11:57:49 +0100 Subject: [PATCH] Wrap WorkspaceType creation in EventuallyWithT Signed-off-by: Nelo-T. Wallus Signed-off-by: Nelo-T. Wallus --- .../virtualworkspace_test.go | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) 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{}) })