no forced whereby recording indicator

server/reflector/pipelines/main_live_pipeline.py

@@ -112,7 +112,7 @@ def get_transcript(func):
         transcript_id = kwargs.pop("transcript_id")
         transcript = await transcripts_controller.get_by_id(transcript_id=transcript_id)
         if not transcript:
-            raise Exception("Transcript {transcript_id} not found")
+            raise Exception(f"Transcript {transcript_id} not found")
 
         # Enhanced logger with Celery task context
         tlogger = logger.bind(transcript_id=transcript.id)

server/reflector/worker/healthcheck.py

@@ -7,6 +7,12 @@ from reflector.settings import settings
 logger = structlog.get_logger(__name__)
 
 
+@shared_task(name="celery.ping")
+def celery_ping():
+    """Compatibility task for Celery 5.x - celery.ping was removed but monitoring tools still call it."""
+    return "pong"
+
+
 @shared_task
 def healthcheck_ping():
     url = settings.HEALTHCHECK_URL