diff --git a/src/summary/summary/core/celery_worker.py b/src/summary/summary/core/celery_worker.py index 1652e0e0..f43709cc 100644 --- a/src/summary/summary/core/celery_worker.py +++ b/src/summary/summary/core/celery_worker.py @@ -59,7 +59,7 @@ def post_with_retries(url, data): session.close() -@celery.task(max_retries=1) +@celery.task(max_retries=settings.celery_max_retries) def process_audio_transcribe_summarize(filename: str, email: str, sub: str): """Process an audio file by transcribing it and generating a summary. diff --git a/src/summary/summary/core/config.py b/src/summary/summary/core/config.py index bc88bd07..c9a50790 100644 --- a/src/summary/summary/core/config.py +++ b/src/summary/summary/core/config.py @@ -19,6 +19,7 @@ class Settings(BaseSettings): # Celery settings celery_broker_url: str = "redis://redis/0" celery_result_backend: str = "redis://redis/0" + celery_max_retries: int = 1 # Minio settings aws_storage_bucket_name: str