From 3c97418a70534705b7578325183a45a278082b00 Mon Sep 17 00:00:00 2001 From: lebaudantoine Date: Thu, 17 Jul 2025 18:03:52 +0200 Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B(summary)=20fix=20Celery=20task=20e?= =?UTF-8?q?xecution=20by=20switching=20to=20apply=5Fasync()?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Replace delay() with apply_async() to resolve invalid arguments error. --- src/summary/summary/api/route/tasks.py | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/src/summary/summary/api/route/tasks.py b/src/summary/summary/api/route/tasks.py index 7fdd0cdc..b6c1d19e 100644 --- a/src/summary/summary/api/route/tasks.py +++ b/src/summary/summary/api/route/tasks.py @@ -36,14 +36,16 @@ async def create_task(request: TaskCreation): request.filename, request.email, request.sub ) else: - task = process_audio_transcribe_summarize_v2.delay( - request.filename, - request.email, - request.sub, - time.time(), - request.room, - request.recording_date, - request.recording_time, + task = process_audio_transcribe_summarize_v2.apply_async( + args=[ + request.filename, + request.email, + request.sub, + time.time(), + request.room, + request.recording_date, + request.recording_time, + ] ) return {"id": task.id, "message": "Task created"}