diff --git a/agents-api/tests/test_execution_workflow.py b/agents-api/tests/test_execution_workflow.py
index 386c1e616..9db44c59a 100644
--- a/agents-api/tests/test_execution_workflow.py
+++ b/agents-api/tests/test_execution_workflow.py
@@ -1,6 +1,7 @@
 # Tests for task queries
 
 import asyncio
+import ward.testing
 import json
 from unittest.mock import patch
 
@@ -9,6 +10,7 @@
     CreateExecutionRequest,
     CreateTaskRequest,
 )
+from agents_api.app import app
 from agents_api.clients.pg import create_db_pool
 from agents_api.queries.tasks.create_task import create_task
 from agents_api.routers.tasks.create_task_execution import start_execution
@@ -25,7 +27,7 @@
 from .utils import patch_integration_service, patch_testing_temporal
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: evaluate step single")
 async def _(
     dsn=pg_dsn,
@@ -34,6 +36,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -62,10 +65,10 @@ async def _(
         mock_run_task_execution_workflow.assert_called_once()
 
         result = await handle.result()
-        assert result["hello"] == "world"
+        assert result["hello"] == "\"world\""
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: evaluate step multiple")
 async def _(
     dsn=pg_dsn,
@@ -74,6 +77,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -105,10 +109,10 @@ async def _(
         mock_run_task_execution_workflow.assert_called_once()
 
         result = await handle.result()
-        assert result["hello"] == "world"
+        assert result["hello"] == "\"world\""
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: variable access in expressions")
 async def _(
     dsn=pg_dsn,
@@ -117,6 +121,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -151,7 +156,7 @@ async def _(
         assert result["hello"] == data.input["test"]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: yield step")
 async def _(
     dsn=pg_dsn,
@@ -160,6 +165,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -201,7 +207,7 @@ async def _(
         assert result["hello"] == data.input["test"]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: sleep step")
 async def _(
     dsn=pg_dsn,
@@ -210,6 +216,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -252,7 +259,7 @@ async def _(
         assert result["hello"] == data.input["test"]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: return step direct")
 async def _(
     dsn=pg_dsn,
@@ -261,6 +268,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -297,7 +305,7 @@ async def _(
         assert result["value"] == data.input["test"]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: return step nested")
 async def _(
     dsn=pg_dsn,
@@ -306,6 +314,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -349,7 +358,7 @@ async def _(
         assert result["value"] == data.input["test"]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: log step")
 async def _(
     dsn=pg_dsn,
@@ -358,6 +367,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -400,7 +410,7 @@ async def _(
         assert result["hello"] == data.input["test"]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: log step expression fail")
 async def _(
     dsn=pg_dsn,
@@ -409,6 +419,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -452,7 +463,7 @@ async def _(
             assert result["hello"] == data.input["test"]
 
 
-@skip("workflow: thread race condition")
+# @skip("workflow: thread race condition")
 @test("workflow: system call - list agents")
 async def _(
     dsn=pg_dsn,
@@ -461,6 +472,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={})
 
     task = await create_task(
@@ -514,7 +526,7 @@ async def _(
         assert all("id" in agent for agent in result)
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: tool call api_call")
 async def _(
     dsn=pg_dsn,
@@ -523,6 +535,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -575,7 +588,7 @@ async def _(
         assert result["hello"] == data.input["test"]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: tool call api_call test retry")
 async def _(
     dsn=pg_dsn,
@@ -584,6 +597,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
     status_codes_to_retry = ",".join(str(code) for code in (408, 429, 503, 504))
 
@@ -648,7 +662,7 @@ async def _(
         assert num_retries >= 2
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: tool call integration dummy")
 async def _(
     dsn=pg_dsn,
@@ -657,6 +671,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -703,7 +718,7 @@ async def _(
         assert result["test"] == data.input["test"]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: tool call integration mocked weather")
 async def _(
     dsn=pg_dsn,
@@ -712,6 +727,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -763,7 +779,7 @@ async def _(
             assert result == expected_output
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: wait for input step start")
 async def _(
     dsn=pg_dsn,
@@ -772,6 +788,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -826,7 +843,7 @@ async def _(
         assert "wait_for_input_step" in activities_scheduled
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: foreach wait for input step start")
 async def _(
     dsn=pg_dsn,
@@ -835,6 +852,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -894,7 +912,7 @@ async def _(
         assert "for_each_step" in activities_scheduled
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: if-else step")
 async def _(
     dsn=pg_dsn,
@@ -903,6 +921,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task_def = CreateTaskRequest(
@@ -943,7 +962,7 @@ async def _(
         assert result["hello"] in [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: switch step")
 async def _(
     dsn=pg_dsn,
@@ -952,6 +971,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -1001,7 +1021,7 @@ async def _(
         assert result["hello"] == "world"
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: for each step")
 async def _(
     dsn=pg_dsn,
@@ -1010,6 +1030,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -1049,7 +1070,7 @@ async def _(
         assert result[0]["hello"] == "world"
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: map reduce step")
 async def _(
     dsn=pg_dsn,
@@ -1058,6 +1079,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     map_step = {
@@ -1101,7 +1123,7 @@ async def _(
 
 for p in [1, 3, 5]:
 
-    @skip("needs to be fixed")
+    # @skip("needs to be fixed")
     @test(f"workflow: map reduce step parallel (parallelism={p})")
     async def _(
         dsn=pg_dsn,
@@ -1110,6 +1132,7 @@ async def _(
         _s3_client=s3_client,  # Adding coz blob store might be used
     ):
         pool = await create_db_pool(dsn=dsn)
+        app.state.postgres_pool = pool
         data = CreateExecutionRequest(input={"test": "input"})
 
         map_step = {
@@ -1157,7 +1180,7 @@ async def _(
             ]
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: prompt step (python expression)")
 async def _(
     dsn=pg_dsn,
@@ -1166,6 +1189,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     mock_model_response = ModelResponse(
         id="fake_id",
         choices=[Choices(message={"role": "assistant", "content": "Hello, world!"})],
@@ -1214,7 +1238,7 @@ async def _(
             assert result["role"] == "assistant"
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: prompt step")
 async def _(
     dsn=pg_dsn,
@@ -1223,6 +1247,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     mock_model_response = ModelResponse(
         id="fake_id",
         choices=[Choices(message={"role": "assistant", "content": "Hello, world!"})],
@@ -1276,7 +1301,7 @@ async def _(
             assert result["role"] == "assistant"
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: prompt step unwrap")
 async def _(
     dsn=pg_dsn,
@@ -1285,6 +1310,7 @@ async def _(
     _s3_client=s3_client,  # Adding coz blob store might be used
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     mock_model_response = ModelResponse(
         id="fake_id",
         choices=[Choices(message={"role": "assistant", "content": "Hello, world!"})],
@@ -1337,7 +1363,7 @@ async def _(
             assert result == "Hello, world!"
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: set and get steps")
 async def _(
     dsn=pg_dsn,
@@ -1345,6 +1371,7 @@ async def _(
     agent=test_agent,
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     data = CreateExecutionRequest(input={"test": "input"})
 
     task = await create_task(
@@ -1380,7 +1407,7 @@ async def _(
         assert result == "test_value"
 
 
-@skip("needs to be fixed")
+# @skip("needs to be fixed")
 @test("workflow: execute yaml task")
 async def _(
     dsn=pg_dsn,
@@ -1388,6 +1415,7 @@ async def _(
     agent=test_agent,
 ):
     pool = await create_db_pool(dsn=dsn)
+    app.state.postgres_pool = pool
     mock_model_response = ModelResponse(
         id="fake_id",
         choices=[
@@ -1432,3 +1460,10 @@ async def _(
             mock_run_task_execution_workflow.assert_called_once()
 
             await handle.result()
+
+
+def always_one():
+    return 1
+
+ward.testing.MAX_PROCESSES = 1  # set global max_process to 1
+ward.testing.available_cpu_count = always_one  # override cpu count
\ No newline at end of file