diff --git a/tests/integration/test_scenarios.py b/tests/integration/test_scenarios.py
index 6070a672f..005bc25aa 100644
--- a/tests/integration/test_scenarios.py
+++ b/tests/integration/test_scenarios.py
@@ -1933,8 +1933,21 @@ async def listen_to_end():
 )
 @pytest.mark.parametrize('initial_task_type', ['new_task', 'status_update'])
 async def test_scenario_initial_task_types(
-    use_legacy, streaming, initial_task_type
+    request, use_legacy, streaming, initial_task_type
 ):
+    if use_legacy and streaming and initial_task_type == 'new_task':
+        # There is a race condition which manifests itself in flaky CI failures.
+        # Given that we don't use legacy by default anymore, xfail it.
+        # Flakiness rate is around 1 failure per 30 runs, so use strict=False
+        # to avoid failing on a passing xfail.
+        request.node.add_marker(
+            pytest.mark.xfail(
+                reason='https://github.com/a2aproject/a2a-python/issues/869',
+                strict=False,
+                raises=ValueError,
+            )
+        )
+
     started_event = asyncio.Event()
     continue_event = asyncio.Event()