Refactor Google ADK plugin initialization and clean up code in worker scripts

Co-authored-by: Copilot <copilot@github.com>

Author: maxjneto

google_adk/basic/run_worker.py

@@ -1,10 +1,9 @@
 from __future__ import annotations
 
 import asyncio
-from datetime import timedelta
 
 from temporalio.client import Client
-from temporalio.contrib.google_adk_agents import GoogleAdkPlugin, ModelActivityParameters
+from temporalio.contrib.google_adk_agents import GoogleAdkPlugin
 from temporalio.worker import Worker
 
 from google_adk.basic.activities.get_weather_activity import get_weather
@@ -16,13 +15,7 @@
 async def main():
     client = await Client.connect(
         "localhost:7233",
-        plugins=[
-            GoogleAdkPlugin(
-                model_params=ModelActivityParameters(
-                    start_to_close_timeout=timedelta(seconds=30)
-                )
-            ),
-        ],
+        plugins=[GoogleAdkPlugin()],
     )
 
     worker = Worker(

google_adk/human_in_the_loop/run_hitl_workflow.py

@@ -52,7 +52,7 @@ async def main():
 
     # Show pending approval and approve it
     for call in pending:
-        print(f"\nPending approval:")
+        print("\nPending approval:")
         print(f"  Tool: {call.tool_name}")
         print(f"  Arguments: {call.arguments}")
         print(f"  Approving call {call.call_id}...")

google_adk/human_in_the_loop/run_worker.py

@@ -1,10 +1,9 @@
 from __future__ import annotations
 
 import asyncio
-from datetime import timedelta
 
 from temporalio.client import Client
-from temporalio.contrib.google_adk_agents import GoogleAdkPlugin, ModelActivityParameters
+from temporalio.contrib.google_adk_agents import GoogleAdkPlugin
 from temporalio.worker import Worker
 
 from google_adk.human_in_the_loop.activities.sensitive_actions import (
@@ -19,13 +18,7 @@
 async def main():
     client = await Client.connect(
         "localhost:7233",
-        plugins=[
-            GoogleAdkPlugin(
-                model_params=ModelActivityParameters(
-                    start_to_close_timeout=timedelta(seconds=30)
-                )
-            ),
-        ],
+        plugins=[GoogleAdkPlugin()],
     )
 
     worker = Worker(

google_adk/human_in_the_loop/workflows/hitl_workflow.py

@@ -81,9 +81,10 @@ async def before_tool_callback(
             )
 
             # Pause until approval signal arrives
-            await workflow.wait_condition(
-                lambda cid=call_id: cid in wf_self._approval_results
-            )
+            def _is_approved(cid: str = call_id) -> bool:
+                return cid in wf_self._approval_results
+
+            await workflow.wait_condition(_is_approved)
 
             # Process approval
             approval = wf_self._approval_results.pop(call_id)

google_adk/orchestration/run_worker.py

@@ -1,10 +1,9 @@
 from __future__ import annotations
 
 import asyncio
-from datetime import timedelta
 
 from temporalio.client import Client
-from temporalio.contrib.google_adk_agents import GoogleAdkPlugin, ModelActivityParameters
+from temporalio.contrib.google_adk_agents import GoogleAdkPlugin
 from temporalio.worker import Worker
 
 from google_adk.orchestration.workflows.loop_workflow import LoopWorkflow
@@ -15,13 +14,7 @@
 async def main():
     client = await Client.connect(
         "localhost:7233",
-        plugins=[
-            GoogleAdkPlugin(
-                model_params=ModelActivityParameters(
-                    start_to_close_timeout=timedelta(seconds=60)
-                )
-            ),
-        ],
+        plugins=[GoogleAdkPlugin()],
     )
 
     worker = Worker(

google_adk/orchestration/workflows/loop_workflow.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 from contextlib import aclosing
-from dataclasses import dataclass
+from dataclasses import dataclass, field
 
 from temporalio import workflow
 from temporalio.contrib.google_adk_agents import TemporalModel
@@ -35,14 +35,10 @@ class LoopInput:
 class OrchestrationOutput:
     """Output from an orchestration workflow."""
 
-    responses: list[str] | None = None
+    responses: list[str] = field(default_factory=list)
     final_response: str = ""
     iterations: int = 0
 
-    def __post_init__(self):
-        if self.responses is None:
-            self.responses = []
-
 
 @workflow.defn
 class LoopWorkflow:

google_adk/orchestration/workflows/sequential_workflow.py

@@ -2,7 +2,6 @@
 
 from contextlib import aclosing
 from dataclasses import dataclass, field
-from typing import Any
 
 from temporalio import workflow
 from temporalio.contrib.google_adk_agents import TemporalModel