diff --git a/examples/tutorials/10_agentic/00_base/000_hello_acp/tests/test_agent.py b/examples/tutorials/10_agentic/00_base/000_hello_acp/tests/test_agent.py
index 8445555f8..50ef513da 100644
--- a/examples/tutorials/10_agentic/00_base/000_hello_acp/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/00_base/000_hello_acp/tests/test_agent.py
@@ -65,7 +65,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # Create a task for this conversation
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -104,7 +104,7 @@ class TestStreamingEvents:
     """Test streaming event sending."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_stream(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_stream(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and streaming the response."""
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
         task = task_response.result
diff --git a/examples/tutorials/10_agentic/00_base/010_multiturn/tests/test_agent.py b/examples/tutorials/10_agentic/00_base/010_multiturn/tests/test_agent.py
index 52165fe1c..7aed7e647 100644
--- a/examples/tutorials/10_agentic/00_base/010_multiturn/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/00_base/010_multiturn/tests/test_agent.py
@@ -65,7 +65,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # TODO: Create a task for this conversation
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/00_base/020_streaming/tests/test_agent.py b/examples/tutorials/10_agentic/00_base/020_streaming/tests/test_agent.py
index 1a39d607b..db424e847 100644
--- a/examples/tutorials/10_agentic/00_base/020_streaming/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/00_base/020_streaming/tests/test_agent.py
@@ -65,7 +65,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # Create a task for this conversation
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/00_base/030_tracing/tests/test_agent.py b/examples/tutorials/10_agentic/00_base/030_tracing/tests/test_agent.py
index e5089e56a..0cc65c566 100644
--- a/examples/tutorials/10_agentic/00_base/030_tracing/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/00_base/030_tracing/tests/test_agent.py
@@ -55,7 +55,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -83,7 +83,7 @@ class TestStreamingEvents:
     """Test streaming event sending."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_stream(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_stream(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and streaming the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/00_base/040_other_sdks/tests/test_agent.py b/examples/tutorials/10_agentic/00_base/040_other_sdks/tests/test_agent.py
index 982dea9d1..13bc084e3 100644
--- a/examples/tutorials/10_agentic/00_base/040_other_sdks/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/00_base/040_other_sdks/tests/test_agent.py
@@ -74,7 +74,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling with MCP tools."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll_simple_query(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll_simple_query(self, client: AsyncAgentex, agent_id: str):
         """Test sending a simple event and polling for the response (no tool use)."""
         # Create a task for this conversation
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/00_base/080_batch_events/tests/test_agent.py b/examples/tutorials/10_agentic/00_base/080_batch_events/tests/test_agent.py
index 4b4d638ab..ce2b55c86 100644
--- a/examples/tutorials/10_agentic/00_base/080_batch_events/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/00_base/080_batch_events/tests/test_agent.py
@@ -66,7 +66,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending a single event and polling for the response."""
         # Create a task for this conversation
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/00_base/090_multi_agent_non_temporal/tests/test_agent.py b/examples/tutorials/10_agentic/00_base/090_multi_agent_non_temporal/tests/test_agent.py
index da764a39e..e9352fdc4 100644
--- a/examples/tutorials/10_agentic/00_base/090_multi_agent_non_temporal/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/00_base/090_multi_agent_non_temporal/tests/test_agent.py
@@ -62,7 +62,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_multi_agent_workflow_complete(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_multi_agent_workflow_complete(self, client: AsyncAgentex, agent_id: str):
         """Test the complete multi-agent workflow with all agents using polling that yields messages."""
         # Create a task for the orchestrator
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -146,7 +146,7 @@ class TestStreamingEvents:
     """Test streaming event sending."""
 
     @pytest.mark.asyncio
-    async def test_multi_agent_workflow_streaming(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_multi_agent_workflow_streaming(self, client: AsyncAgentex, agent_id: str):
         """Test the multi-agent workflow with streaming responses and early exit."""
         # Create a task for the orchestrator
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/10_temporal/000_hello_acp/tests/test_agent.py b/examples/tutorials/10_agentic/10_temporal/000_hello_acp/tests/test_agent.py
index 02ff6bedc..31d8f4e49 100644
--- a/examples/tutorials/10_agentic/10_temporal/000_hello_acp/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/10_temporal/000_hello_acp/tests/test_agent.py
@@ -65,7 +65,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # Create a task for this conversation
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -104,7 +104,7 @@ class TestStreamingEvents:
     """Test streaming event sending."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_stream(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_stream(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and streaming the response."""
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
         task = task_response.result
diff --git a/examples/tutorials/10_agentic/10_temporal/010_agent_chat/tests/test_agent.py b/examples/tutorials/10_agentic/10_temporal/010_agent_chat/tests/test_agent.py
index 998740762..025693ecc 100644
--- a/examples/tutorials/10_agentic/10_temporal/010_agent_chat/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/10_temporal/010_agent_chat/tests/test_agent.py
@@ -74,7 +74,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling with OpenAI Agents SDK."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll_simple_query(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll_simple_query(self, client: AsyncAgentex, agent_id: str):
         """Test sending a simple event and polling for the response (no tool use)."""
         # Create a task for this conversation
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/10_temporal/020_state_machine/tests/test_agent.py b/examples/tutorials/10_agentic/10_temporal/020_state_machine/tests/test_agent.py
index 207c40b3f..41038c22b 100644
--- a/examples/tutorials/10_agentic/10_temporal/020_state_machine/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/10_temporal/020_state_machine/tests/test_agent.py
@@ -72,7 +72,7 @@ async def agent_id(client, agent_name):
 class TestNonStreamingEvents:
     """Test non-streaming event sending and polling with state machine workflow."""
     @pytest.mark.asyncio
-    async def test_send_event_and_poll_simple_query(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll_simple_query(self, client: AsyncAgentex, agent_id: str):
         """Test sending a simple event and polling for the response (no tool use)."""
         # Create a task for this conversation
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -127,7 +127,7 @@ async def test_send_event_and_poll_simple_query(self, client: AsyncAgentex, _age
 class TestStreamingEvents:
     """Test streaming event sending with state machine workflow."""
     @pytest.mark.asyncio
-    async def test_send_event_and_stream(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_stream(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and streaming the response."""
         # Create a task for this conversation
         task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/10_temporal/030_custom_activities/tests/test_agent.py b/examples/tutorials/10_agentic/10_temporal/030_custom_activities/tests/test_agent.py
index d57d34ff7..b839332c7 100644
--- a/examples/tutorials/10_agentic/10_temporal/030_custom_activities/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/10_temporal/030_custom_activities/tests/test_agent.py
@@ -55,7 +55,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -97,7 +97,7 @@ class TestStreamingEvents:
     """Test streaming event sending."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_stream(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_stream(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and streaming the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/10_temporal/050_agent_chat_guardrails/tests/test_agent.py b/examples/tutorials/10_agentic/10_temporal/050_agent_chat_guardrails/tests/test_agent.py
index d6d4da018..1b1f7a400 100644
--- a/examples/tutorials/10_agentic/10_temporal/050_agent_chat_guardrails/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/10_temporal/050_agent_chat_guardrails/tests/test_agent.py
@@ -55,7 +55,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -97,7 +97,7 @@ class TestStreamingEvents:
     """Test streaming event sending."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_stream(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_stream(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and streaming the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/10_temporal/060_open_ai_agents_sdk_hello_world/tests/test_agent.py b/examples/tutorials/10_agentic/10_temporal/060_open_ai_agents_sdk_hello_world/tests/test_agent.py
index 551999a1a..8cdcac932 100644
--- a/examples/tutorials/10_agentic/10_temporal/060_open_ai_agents_sdk_hello_world/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/10_temporal/060_open_ai_agents_sdk_hello_world/tests/test_agent.py
@@ -55,7 +55,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -97,7 +97,7 @@ class TestStreamingEvents:
     """Test streaming event sending."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_stream(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_stream(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and streaming the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/10_temporal/070_open_ai_agents_sdk_tools/tests/test_agent.py b/examples/tutorials/10_agentic/10_temporal/070_open_ai_agents_sdk_tools/tests/test_agent.py
index 551999a1a..8cdcac932 100644
--- a/examples/tutorials/10_agentic/10_temporal/070_open_ai_agents_sdk_tools/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/10_temporal/070_open_ai_agents_sdk_tools/tests/test_agent.py
@@ -55,7 +55,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -97,7 +97,7 @@ class TestStreamingEvents:
     """Test streaming event sending."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_stream(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_stream(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and streaming the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/10_agentic/10_temporal/080_open_ai_agents_sdk_human_in_the_loop/tests/test_agent.py b/examples/tutorials/10_agentic/10_temporal/080_open_ai_agents_sdk_human_in_the_loop/tests/test_agent.py
index 551999a1a..8cdcac932 100644
--- a/examples/tutorials/10_agentic/10_temporal/080_open_ai_agents_sdk_human_in_the_loop/tests/test_agent.py
+++ b/examples/tutorials/10_agentic/10_temporal/080_open_ai_agents_sdk_human_in_the_loop/tests/test_agent.py
@@ -55,7 +55,7 @@ class TestNonStreamingEvents:
     """Test non-streaming event sending and polling."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_poll(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_poll(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and polling for the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
@@ -97,7 +97,7 @@ class TestStreamingEvents:
     """Test streaming event sending."""
 
     @pytest.mark.asyncio
-    async def test_send_event_and_stream(self, client: AsyncAgentex, _agent_name: str, agent_id: str):
+    async def test_send_event_and_stream(self, client: AsyncAgentex, agent_id: str):
         """Test sending an event and streaming the response."""
         # TODO: Create a task for this conversation
         # task_response = await client.agents.create_task(agent_id, params=ParamsCreateTaskRequest(name=uuid.uuid1().hex))
diff --git a/examples/tutorials/run_all_agentic_tests.sh b/examples/tutorials/run_all_agentic_tests.sh
index f24542632..73883237d 100755
--- a/examples/tutorials/run_all_agentic_tests.sh
+++ b/examples/tutorials/run_all_agentic_tests.sh
@@ -94,7 +94,8 @@ wait_for_agent_ready() {
     echo -e "${YELLOW}⏳ Waiting for ${name} agent to be ready...${NC}"
 
     while [ $elapsed -lt $timeout ]; do
-        if grep -q "Application startup complete" "$logfile" 2>/dev/null; then
+        if grep -q "Application startup complete" "$logfile" 2>/dev/null || \
+           grep -q "Running workers for task queue" "$logfile" 2>/dev/null; then
             echo -e "${GREEN}✅ ${name} agent is ready${NC}"
             return 0
         fi
@@ -382,4 +383,4 @@ main() {
 }
 
 # Run main function
-main
+main
\ No newline at end of file