Skip to content

Commit 798bded

Browse files
committed
Fix flaky test.
1 parent 632c612 commit 798bded

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

coordinator/coordinator_test.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -191,7 +191,7 @@ func testHappyPath[Data, Metadata any](t *testing.T, d testCase[Data, Metadata],
191191
require.NoError(t, errE, "% -+#.1v", errE)
192192
assert.Equal(t, int64(1), i)
193193

194-
time.Sleep(10 * time.Millisecond)
194+
time.Sleep(100 * time.Millisecond)
195195
appended := appendedChannelContents.Prune()
196196
if assert.Len(t, appended, 1) {
197197
assert.Equal(t, coordinator.AppendedOperation{
@@ -204,7 +204,7 @@ func testHappyPath[Data, Metadata any](t *testing.T, d testCase[Data, Metadata],
204204
require.NoError(t, errE, "% -+#.1v", errE)
205205
assert.Equal(t, int64(2), i)
206206

207-
time.Sleep(10 * time.Millisecond)
207+
time.Sleep(100 * time.Millisecond)
208208
appended = appendedChannelContents.Prune()
209209
if assert.Len(t, appended, 1) {
210210
assert.Equal(t, coordinator.AppendedOperation{
@@ -218,7 +218,7 @@ func testHappyPath[Data, Metadata any](t *testing.T, d testCase[Data, Metadata],
218218
require.NoError(t, errE, "% -+#.1v", errE)
219219
assert.Equal(t, int64(3), i)
220220

221-
time.Sleep(10 * time.Millisecond)
221+
time.Sleep(100 * time.Millisecond)
222222
appended = appendedChannelContents.Prune()
223223
if assert.Len(t, appended, 1) {
224224
assert.Equal(t, coordinator.AppendedOperation{
@@ -232,7 +232,7 @@ func testHappyPath[Data, Metadata any](t *testing.T, d testCase[Data, Metadata],
232232
require.NoError(t, errE, "% -+#.1v", errE)
233233
assert.Equal(t, int64(4), i)
234234

235-
time.Sleep(10 * time.Millisecond)
235+
time.Sleep(100 * time.Millisecond)
236236
appended = appendedChannelContents.Prune()
237237
if assert.Len(t, appended, 1) {
238238
assert.Equal(t, coordinator.AppendedOperation{
@@ -299,7 +299,7 @@ func testHappyPath[Data, Metadata any](t *testing.T, d testCase[Data, Metadata],
299299
assert.Equal(t, d.BeginMetadata, beginMetadata)
300300
assert.Equal(t, d.EndMetadata, endMetadata)
301301

302-
time.Sleep(10 * time.Millisecond)
302+
time.Sleep(100 * time.Millisecond)
303303
ended := endedChannelContents.Prune()
304304
if assert.Len(t, ended, 1) {
305305
assert.Equal(t, session, ended[0])
@@ -407,7 +407,7 @@ func TestListPagination(t *testing.T) {
407407

408408
assert.Equal(t, operations, allPages)
409409

410-
time.Sleep(10 * time.Millisecond)
410+
time.Sleep(100 * time.Millisecond)
411411
appended := appendedChannelContents.Prune()
412412
assert.Len(t, appended, 6000)
413413

0 commit comments

Comments
 (0)