diff --git a/test_elasticsearch_serverless/test_async/test_server/test_helpers.py b/test_elasticsearch_serverless/test_async/test_server/test_helpers.py
index ac7fbc6..d0aac44 100644
--- a/test_elasticsearch_serverless/test_async/test_server/test_helpers.py
+++ b/test_elasticsearch_serverless/test_async/test_server/test_helpers.py
@@ -917,10 +917,7 @@ async def test_reindex_accepts_a_query(self, async_client, reindex_setup):
 
     async def test_all_documents_get_moved(self, async_client, reindex_setup):
         await helpers.async_reindex(
-            async_client,
-            "test_index",
-            "prod_index",
-            bulk_kwargs={"refresh": "wait_for"},
+            async_client, "test_index", "prod_index", bulk_kwargs={"refresh": True}
         )
 
         assert await async_client.indices.exists(index="prod_index")