Add missing refreshes in bulk test

We can't get the failure if we're not asking for a refresh.

Author: pquentin

test_elasticsearch_serverless/test_async/test_server/test_helpers.py

@@ -366,34 +366,47 @@ async def test_error_is_raised(self, async_client):
     async def test_ignore_error_if_raised(self, async_client):
         # ignore the status code 400 in tuple
         await helpers.async_bulk(
-            async_client, [{"a": 42}, {"a": "c"}], index="i", ignore_status=(400,)
+            async_client,
+            [{"a": 42}, {"a": "c"}],
+            index="i",
+            refresh=True,
+            ignore_status=(400,),
         )
 
         # ignore the status code 400 in list
         await helpers.async_bulk(
             async_client,
             [{"a": 42}, {"a": "c"}],
             index="i",
+            refresh=True,
             ignore_status=[
                 400,
             ],
         )
 
         # ignore the status code 400
         await helpers.async_bulk(
-            async_client, [{"a": 42}, {"a": "c"}], index="i", ignore_status=400
+            async_client,
+            [{"a": 42}, {"a": "c"}],
+            index="i",
+            refresh=True,
+            ignore_status=400,
         )
 
         # ignore only the status code in the `ignore_status` argument
         with pytest.raises(helpers.BulkIndexError):
             await helpers.async_bulk(
-                async_client, [{"a": 42}, {"a": "c"}], index="i", ignore_status=(444,)
+                async_client,
+                [{"a": 42}, {"a": "c"}],
+                index="i",
+                refresh=True,
+                ignore_status=(444,),
             )
 
         # ignore transport error exception
         failing_client = FailingBulkClient(async_client)
         await helpers.async_bulk(
-            failing_client, [{"a": 42}], index="i", ignore_status=(599,)
+            failing_client, [{"a": 42}], index="i", refresh=True, ignore_status=(599,)
         )
 
     async def test_errors_are_collected_properly(self, async_client):

test_elasticsearch_serverless/test_server/test_helpers.py

@@ -357,33 +357,45 @@ def test_error_is_raised(sync_client):
 
 def test_ignore_error_if_raised(sync_client):
     # ignore the status code 400 in tuple
-    helpers.bulk(sync_client, [{"a": 42}, {"a": "c"}], index="i", ignore_status=(400,))
+    helpers.bulk(
+        sync_client,
+        [{"a": 42}, {"a": "c"}],
+        index="i",
+        refresh=True,
+        ignore_status=(400,),
+    )
 
     # ignore the status code 400 in list
     helpers.bulk(
         sync_client,
         [{"a": 42}, {"a": "c"}],
         index="i",
+        refresh=True,
         ignore_status=[
             400,
         ],
     )
 
     # ignore the status code 400
-    helpers.bulk(sync_client, [{"a": 42}, {"a": "c"}], index="i", ignore_status=400)
+    helpers.bulk(
+        sync_client, [{"a": 42}, {"a": "c"}], index="i", refresh=True, ignore_status=400
+    )
 
     # ignore only the status code in the `ignore_status` argument
     with pytest.raises(helpers.BulkIndexError):
         helpers.bulk(
             sync_client,
             [{"a": 42}, {"a": "c"}],
             index="i",
+            refresh=True,
             ignore_status=(444,),
         )
 
     # ignore transport error exception
     failing_client = FailingBulkClient(sync_client)
-    helpers.bulk(failing_client, [{"a": 42}], index="i", ignore_status=(599,))
+    helpers.bulk(
+        failing_client, [{"a": 42}], index="i", refresh=True, ignore_status=(599,)
+    )
 
 
 def test_errors_are_collected_properly(sync_client):