Add xfail markers

Author: pquentin

test_elasticsearch_serverless/test_async/test_server/test_helpers.py

@@ -30,6 +30,8 @@
 pytestmark = [pytest.mark.asyncio]
 
 
+async_bulk_xfail = pytest.mark.xfail(sys.version_info(sys.version_info < (3, 11)), reason="Investigated in issue #62")
+
 class AsyncMock(MagicMock):
     async def __call__(self, *args, **kwargs):
         return super(AsyncMock, self).__call__(*args, **kwargs)
@@ -76,6 +78,7 @@ async def test_actions_remain_unchanged(self, async_client):
             assert ok
         assert [{"_id": 1}, {"_id": 2}] == actions
 
+    @async_bulk_xfail
     async def test_all_documents_get_inserted(self, async_client):
         docs = [{"answer": x, "_id": x} for x in range(100)]
         async for ok, item in helpers.async_streaming_bulk(
@@ -88,6 +91,7 @@ async def test_all_documents_get_inserted(self, async_client):
             "_source"
         ]
 
+    @async_bulk_xfail
     async def test_documents_data_types(self, async_client):
         async def async_gen():
             for x in range(100):
@@ -306,6 +310,7 @@ async def test_bulk_works_with_single_item(self, async_client):
             "_source"
         ]
 
+    @async_bulk_xfail
     async def test_all_documents_get_inserted(self, async_client):
         docs = [{"answer": x, "_id": x} for x in range(100)]
         success, failed = await helpers.async_bulk(
@@ -319,6 +324,7 @@ async def test_all_documents_get_inserted(self, async_client):
             "_source"
         ]
 
+    @async_bulk_xfail
     async def test_stats_only_reports_numbers(self, async_client):
         docs = [{"answer": x} for x in range(100)]
         success, failed = await helpers.async_bulk(
@@ -454,6 +460,7 @@ async def scan_teardown(async_client):
 
 
 class TestScan(object):
+    @async_bulk_xfail
     async def test_order_can_be_preserved(self, async_client, scan_teardown):
         bulk = []
         for x in range(100):
@@ -886,6 +893,7 @@ async def reindex_setup(async_client):
 
 
 class TestReindex(object):
+    @async_bulk_xfail
     async def test_reindex_passes_kwargs_to_scan_and_bulk(
         self, async_client, reindex_setup
     ):
@@ -907,6 +915,7 @@ async def test_reindex_passes_kwargs_to_scan_and_bulk(
             await async_client.get(index="prod_index", id=42)
         )["_source"]
 
+    @async_bulk_xfail
     async def test_reindex_accepts_a_query(self, async_client, reindex_setup):
         await helpers.async_reindex(
             async_client,
@@ -926,6 +935,7 @@ async def test_reindex_accepts_a_query(self, async_client, reindex_setup):
             await async_client.get(index="prod_index", id=42)
         )["_source"]
 
+    @async_bulk_xfail
     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": True}
@@ -976,6 +986,7 @@ async def reindex_data_stream_setup(async_client):
 
 class TestAsyncDataStreamReindex(object):
     @pytest.mark.parametrize("op_type", [None, "create"])
+    @async_bulk_xfail
     async def test_reindex_index_datastream(
         self, op_type, async_client, reindex_data_stream_setup
     ):
@@ -995,6 +1006,7 @@ async def test_reindex_index_datastream(
             ]
         )
 
+    @async_bulk_xfail
     async def test_reindex_index_datastream_op_type_index(
         self, async_client, reindex_data_stream_setup
     ):