Skip to content

Commit 9a650e6

Browse files
authored
Remove unneeded refreshes (#2574)
1 parent f0c4dbe commit 9a650e6

File tree

2 files changed

+0
-8
lines changed

2 files changed

+0
-8
lines changed

test_elasticsearch/test_async/test_server/test_helpers.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,6 @@ async def test_all_errors_from_chunk_are_raised_on_failure(self, async_client):
129129
mappings={"properties": {"a": {"type": "integer"}}},
130130
settings={"number_of_shards": 1, "number_of_replicas": 0},
131131
)
132-
await async_client.cluster.health(wait_for_status="yellow")
133132

134133
try:
135134
async for ok, item in helpers.async_streaming_bulk(
@@ -338,7 +337,6 @@ async def test_errors_are_reported_correctly(self, async_client):
338337
mappings={"properties": {"a": {"type": "integer"}}},
339338
settings={"number_of_shards": 1, "number_of_replicas": 0},
340339
)
341-
await async_client.cluster.health(wait_for_status="yellow")
342340

343341
success, failed = await helpers.async_bulk(
344342
async_client,
@@ -364,7 +362,6 @@ async def test_error_is_raised(self, async_client):
364362
mappings={"properties": {"a": {"type": "integer"}}},
365363
settings={"number_of_shards": 1, "number_of_replicas": 0},
366364
)
367-
await async_client.cluster.health(wait_for_status="yellow")
368365

369366
with pytest.raises(helpers.BulkIndexError):
370367
await helpers.async_bulk(async_client, [{"a": 42}, {"a": "c"}], index="i")
@@ -408,7 +405,6 @@ async def test_errors_are_collected_properly(self, async_client):
408405
mappings={"properties": {"a": {"type": "integer"}}},
409406
settings={"number_of_shards": 1, "number_of_replicas": 0},
410407
)
411-
await async_client.cluster.health(wait_for_status="yellow")
412408

413409
success, failed = await helpers.async_bulk(
414410
async_client,

test_elasticsearch/test_server/test_helpers.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,6 @@ def test_bulk_all_errors_from_chunk_are_raised_on_failure(sync_client):
8282
"settings": {"number_of_shards": 1, "number_of_replicas": 0},
8383
},
8484
)
85-
sync_client.cluster.health(wait_for_status="yellow")
8685

8786
try:
8887
for ok, _ in helpers.streaming_bulk(
@@ -325,7 +324,6 @@ def test_errors_are_reported_correctly(sync_client):
325324
mappings={"properties": {"a": {"type": "integer"}}},
326325
settings={"number_of_shards": 1, "number_of_replicas": 0},
327326
)
328-
sync_client.cluster.health(wait_for_status="yellow")
329327

330328
success, failed = helpers.bulk(
331329
sync_client,
@@ -352,7 +350,6 @@ def test_error_is_raised(sync_client):
352350
mappings={"properties": {"a": {"type": "integer"}}},
353351
settings={"number_of_shards": 1, "number_of_replicas": 0},
354352
)
355-
sync_client.cluster.health(wait_for_status="yellow")
356353

357354
with pytest.raises(helpers.BulkIndexError):
358355
helpers.bulk(
@@ -399,7 +396,6 @@ def test_errors_are_collected_properly(sync_client):
399396
mappings={"properties": {"a": {"type": "integer"}}},
400397
settings={"number_of_shards": 1, "number_of_replicas": 0},
401398
)
402-
sync_client.cluster.health(wait_for_status="yellow")
403399

404400
success, failed = helpers.bulk(
405401
sync_client,

0 commit comments

Comments
 (0)