fix: Start workflows asynchronously

julep-ai · Sep 17, 2024 · 13f528e · 13f528e
1 parent 1847be2
commit 13f528e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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",