@@ -126,7 +126,6 @@ async def test_all_errors_from_chunk_are_raised_on_failure(self, async_client):
126
126
index = "i" ,
127
127
mappings = {"properties" : {"a" : {"type" : "integer" }}},
128
128
)
129
- await async_client .cluster .health (wait_for_status = "yellow" )
130
129
131
130
try :
132
131
async for ok , item in helpers .async_streaming_bulk (
@@ -334,7 +333,6 @@ async def test_errors_are_reported_correctly(self, async_client):
334
333
index = "i" ,
335
334
mappings = {"properties" : {"a" : {"type" : "integer" }}},
336
335
)
337
- await async_client .cluster .health (wait_for_status = "yellow" )
338
336
339
337
success , failed = await helpers .async_bulk (
340
338
async_client ,
@@ -357,7 +355,6 @@ async def test_error_is_raised(self, async_client):
357
355
index = "i" ,
358
356
mappings = {"properties" : {"a" : {"type" : "integer" }}},
359
357
)
360
- await async_client .cluster .health (wait_for_status = "yellow" )
361
358
362
359
with pytest .raises (helpers .BulkIndexError ):
363
360
await helpers .async_bulk (async_client , [{"a" : 42 }, {"a" : "c" }], index = "i" )
@@ -400,7 +397,6 @@ async def test_errors_are_collected_properly(self, async_client):
400
397
index = "i" ,
401
398
mappings = {"properties" : {"a" : {"type" : "integer" }}},
402
399
)
403
- await async_client .cluster .health (wait_for_status = "yellow" )
404
400
405
401
success , failed = await helpers .async_bulk (
406
402
async_client ,
0 commit comments