From d2de5ba1b57aa78ac52224a9a050480c1e657090 Mon Sep 17 00:00:00 2001 From: Giles Odigwe Date: Thu, 30 Apr 2026 09:43:06 -0700 Subject: [PATCH] Revert "Re-enable workflow parallel tests with xdist_group marker" This reverts commit 455c28da6240997ce98144fb6f07eec0063f4baa. --- .../tests/integration_tests/test_11_workflow_parallel.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/python/packages/azurefunctions/tests/integration_tests/test_11_workflow_parallel.py b/python/packages/azurefunctions/tests/integration_tests/test_11_workflow_parallel.py index 1608edac72..65a96678a1 100644 --- a/python/packages/azurefunctions/tests/integration_tests/test_11_workflow_parallel.py +++ b/python/packages/azurefunctions/tests/integration_tests/test_11_workflow_parallel.py @@ -29,7 +29,6 @@ pytestmark = [ pytest.mark.integration, pytest.mark.sample("11_workflow_parallel"), pytest.mark.usefixtures("function_app_for_test"), - pytest.mark.xdist_group("workflow_parallel"), ] @@ -43,6 +42,7 @@ class TestWorkflowParallel: self.base_url = base_url self.helper = sample_helper + @pytest.mark.skip(reason="xdist distributes module tests across workers, each spawning a func process") def test_parallel_workflow_document_analysis(self) -> None: """Test parallel workflow with a standard document.""" payload = { @@ -71,6 +71,7 @@ class TestWorkflowParallel: assert status["runtimeStatus"] == "Completed" assert "output" in status + @pytest.mark.skip(reason="xdist distributes module tests across workers, each spawning a func process") def test_parallel_workflow_short_document(self) -> None: """Test parallel workflow with a short document.""" payload = { @@ -90,6 +91,7 @@ class TestWorkflowParallel: assert status["runtimeStatus"] == "Completed" assert "output" in status + @pytest.mark.skip(reason="xdist distributes module tests across workers, each spawning a func process") def test_parallel_workflow_technical_document(self) -> None: """Test parallel workflow with a technical document.""" payload = { @@ -113,6 +115,7 @@ class TestWorkflowParallel: status = self.helper.wait_for_orchestration_with_output(data["statusQueryGetUri"], max_wait=300) assert status["runtimeStatus"] == "Completed" + @pytest.mark.skip(reason="xdist distributes module tests across workers, each spawning a func process") def test_workflow_status_endpoint(self) -> None: """Test that the workflow status endpoint works correctly.""" payload = {