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 65a96678a1..1608edac72 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,6 +29,7 @@ pytestmark = [
     pytest.mark.integration,
     pytest.mark.sample("11_workflow_parallel"),
     pytest.mark.usefixtures("function_app_for_test"),
+    pytest.mark.xdist_group("workflow_parallel"),
 ]
 
 
@@ -42,7 +43,6 @@ 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,7 +71,6 @@ 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 = {
@@ -91,7 +90,6 @@ 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 = {
@@ -115,7 +113,6 @@ 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 = {