CloudMigration: fix flacky test (#111046)

This commit is contained in:
lean.dev
2025-09-12 20:46:11 +01:00
committed by GitHub
parent 3e086d1133
commit c52eedbf23
@@ -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) {