From 13f528e935acbaa3b9934813e12dd957b9795f09 Mon Sep 17 00:00:00 2001 From: Dmitry Paramonov Date: Tue, 17 Sep 2024 17:10:29 +0300 Subject: [PATCH] fix: Start workflows asynchronously --- agents-api/agents_api/clients/temporal.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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",