diff --git a/Makefile b/Makefile index 905d1a7a..9038f055 100644 --- a/Makefile +++ b/Makefile @@ -118,7 +118,7 @@ run-backend: ## start only the backend application and all needed services .PHONY: run-backend run-summary: ## start only the summary application and all needed services - @$(COMPOSE) up --force-recreate -d celery-summary + @$(COMPOSE) up --force-recreate -d celery-summary-transcribe .PHONY: run-summary run: diff --git a/compose.yml b/compose.yml index c9a795db..7f8c04d0 100644 --- a/compose.yml +++ b/compose.yml @@ -243,13 +243,13 @@ services: depends_on: - redis-summary - celery-summary: - container_name: celery-summary + celery-summary-transcribe: + container_name: celery-summary-transcribe build: context: ./src/summary dockerfile: Dockerfile target: production - command: celery -A summary.core.celery_worker worker --pool=solo --loglevel=debug + command: celery -A summary.core.celery_worker worker --pool=solo --loglevel=debug -Q transcribe-queue env_file: - env.d/development/summary volumes: diff --git a/src/summary/summary/api/route/tasks.py b/src/summary/summary/api/route/tasks.py index bc9a89c4..37895e9e 100644 --- a/src/summary/summary/api/route/tasks.py +++ b/src/summary/summary/api/route/tasks.py @@ -10,6 +10,9 @@ from pydantic import BaseModel from summary.core.celery_worker import ( process_audio_transcribe_summarize_v2, ) +from summary.core.config import get_settings + +settings = get_settings() class TaskCreation(BaseModel): @@ -39,7 +42,8 @@ async def create_task(request: TaskCreation): request.room, request.recording_date, request.recording_time, - ] + ], + queue=settings.transcribe_queue, ) return {"id": task.id, "message": "Task created"} diff --git a/src/summary/summary/core/config.py b/src/summary/summary/core/config.py index 9b61be18..b65e9281 100644 --- a/src/summary/summary/core/config.py +++ b/src/summary/summary/core/config.py @@ -24,6 +24,8 @@ class Settings(BaseSettings): celery_result_backend: str = "redis://redis/0" celery_max_retries: int = 1 + transcribe_queue: str = "transcribe-queue" + # Minio settings aws_storage_bucket_name: str aws_s3_endpoint_url: str