From c52eedbf23be6921152ce95d59b9986c6c840fb5 Mon Sep 17 00:00:00 2001 From: "lean.dev" <34773040+leandro-deveikis@users.noreply.github.com> Date: Fri, 12 Sep 2025 20:46:11 +0100 Subject: [PATCH] CloudMigration: fix flacky test (#111046) --- .../cloudmigrationimpl/cloudmigration_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/pkg/services/cloudmigration/cloudmigrationimpl/cloudmigration_test.go b/pkg/services/cloudmigration/cloudmigrationimpl/cloudmigration_test.go index 6b1e89f3096..948c63ea613 100644 --- a/pkg/services/cloudmigration/cloudmigrationimpl/cloudmigration_test.go +++ b/pkg/services/cloudmigration/cloudmigrationimpl/cloudmigration_test.go @@ -176,7 +176,7 @@ func Test_GetSnapshotStatusFromGMS(t *testing.T) { }) require.NoError(t, err) require.Eventually(t, checkStatusSync(ctx, s, snapshotUID, sessionUID, cloudmigration.SnapshotStatusPendingProcessing), time.Second, 10*time.Millisecond) - require.Equal(t, 1, gmsClientFake.GetSnapshotStatusCallCount()) + require.True(t, gmsClientFake.GetSnapshotStatusCallCount() >= 1) }) t.Run("test case: gms snapshot processing", func(t *testing.T) { @@ -200,7 +200,7 @@ func Test_GetSnapshotStatusFromGMS(t *testing.T) { }) require.NoError(t, err) require.Eventually(t, checkStatusSync(ctx, s, snapshotUID, sessionUID, cloudmigration.SnapshotStatusProcessing), time.Second, 10*time.Millisecond) - require.Equal(t, 1, gmsClientFake.GetSnapshotStatusCallCount()) + require.True(t, gmsClientFake.GetSnapshotStatusCallCount() >= 1) }) t.Run("test case: gms snapshot finished", func(t *testing.T) { @@ -224,7 +224,7 @@ func Test_GetSnapshotStatusFromGMS(t *testing.T) { }) require.NoError(t, err) require.Eventually(t, checkStatusSync(ctx, s, snapshotUID, sessionUID, cloudmigration.SnapshotStatusFinished), time.Second, 10*time.Millisecond) - require.Equal(t, 1, gmsClientFake.GetSnapshotStatusCallCount()) + require.True(t, gmsClientFake.GetSnapshotStatusCallCount() >= 1) }) t.Run("test case: gms snapshot canceled", func(t *testing.T) { @@ -248,7 +248,7 @@ func Test_GetSnapshotStatusFromGMS(t *testing.T) { }) require.NoError(t, err) require.Eventually(t, checkStatusSync(ctx, s, snapshotUID, sessionUID, cloudmigration.SnapshotStatusCanceled), time.Second, 10*time.Millisecond) - require.Equal(t, 1, gmsClientFake.GetSnapshotStatusCallCount()) + require.True(t, gmsClientFake.GetSnapshotStatusCallCount() >= 1) }) t.Run("test case: gms snapshot error", func(t *testing.T) { @@ -272,7 +272,7 @@ func Test_GetSnapshotStatusFromGMS(t *testing.T) { }) require.NoError(t, err) require.Eventually(t, checkStatusSync(ctx, s, snapshotUID, sessionUID, cloudmigration.SnapshotStatusError), time.Second, 10*time.Millisecond) - assert.Equal(t, 1, gmsClientFake.GetSnapshotStatusCallCount()) + assert.True(t, gmsClientFake.GetSnapshotStatusCallCount() >= 1) }) t.Run("test case: gms snapshot unknown", func(t *testing.T) {