diff --git a/agents-api/agents_api/clients/temporal.py b/agents-api/agents_api/clients/temporal.py index 9cd5fbe47..873ce5c97 100644 --- a/agents-api/agents_api/clients/temporal.py +++ b/agents-api/agents_api/clients/temporal.py @@ -77,7 +77,7 @@ async def run_truncation_task( ): client = await get_client() - await client.execute_workflow( + await client.start_workflow( "TruncationWorkflow", args=[str(developer_id), str(session_id), token_count_threshold], task_queue="memory-task-queue", @@ -88,7 +88,7 @@ async def run_truncation_task( async def run_summarization_task(session_id: UUID, job_id: UUID): client = await get_client() - await client.execute_workflow( + await client.start_workflow( "SummarizationWorkflow", args=[str(session_id)], task_queue="memory-task-queue",