Skip to content

Commit 155aa5f

Browse files
committed
stores: fix test timeout flake
1 parent f3a255c commit 155aa5f

File tree

1 file changed

+6
-10
lines changed

1 file changed

+6
-10
lines changed

broker/stores/stores_test.go

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -358,19 +358,15 @@ func TestHealthStatusAfterSweep(t *testing.T) {
358358
},
359359
})
360360

361-
// Create a store
362-
store := Get(pb.FragmentStore("s3://test/"))
361+
var store = Get(pb.FragmentStore("s3://test/"))
363362
require.NoError(t, store.initErr)
364363

365364
// Wait for initial health check to complete
366-
done, _ := store.HealthStatus()
367-
<-done
368-
369-
// Update health to success
370-
store.UpdateHealth(nil)
371-
372-
// Verify health is good
373-
var _, err = store.HealthStatus()
365+
done, err := store.HealthStatus()
366+
if err == ErrFirstHealthCheck {
367+
<-done
368+
}
369+
_, err = store.HealthStatus()
374370
require.NoError(t, err)
375371

376372
// First sweep clears the mark (store was marked on creation)

0 commit comments

Comments
 (0)