Fix temporal as well

Author: jasonyang101

src/agentex/lib/core/temporal/services/temporal_task_service.py

@@ -1,3 +1,4 @@
+from typing import Any
 from agentex.lib.core.clients.temporal.temporal_client import TemporalClient
 from agentex.lib.core.clients.temporal.types import WorkflowState
 from agentex.lib.core.temporal.types.workflow import SignalName
@@ -22,7 +23,7 @@ def __init__(
         self._temporal_client = temporal_client
         self._env_vars = env_vars
 
-    async def submit_task(self, agent: Agent, task: Task) -> str:
+    async def submit_task(self, agent: Agent, task: Task, params: dict[str, Any] | None) -> str:
         """
         Submit a task to the async runtime for execution.
 
@@ -33,7 +34,7 @@ async def submit_task(self, agent: Agent, task: Task) -> str:
             arg=CreateTaskParams(
                 agent=agent,
                 task=task,
-                params=None,
+                params=params,
             ),
             id=task.id,
             task_queue=self._env_vars.WORKFLOW_TASK_QUEUE,

src/agentex/lib/sdk/fastacp/impl/temporal_acp.py

@@ -71,7 +71,7 @@ def _setup_handlers(self):
         async def handle_task_create(params: CreateTaskParams) -> None:
             """Default create task handler - logs the task"""
             logger.info(f"TemporalACP received task create rpc call for task {params.task.id}")
-            await self._temporal_task_service.submit_task(agent=params.agent, task=params.task)
+            await self._temporal_task_service.submit_task(agent=params.agent, task=params.task, params=params.params)
 
         @self.on_task_event_send
         async def handle_event_send(params: SendEventParams) -> None: