studio/meet
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🔊(summary) increase logging level to info for Celery worker insights

Browse Source 
Change logging levels to provide more visibility into Celery worker
operations and task processing for better monitoring.
This commit is contained in:
lebaudantoine
2025-07-10 12:01:32 +02:00
committed by aleb_the_flash
parent 1716e11900
commit 921d69031e
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/summary/summary/core/celery_worker.py
View File

@@ -174,7 +174,8 @@ def process_audio_transcribe_summarize(filename: str, email: str, sub: str):
temp_file_path = save_audio_stream(audio_file_stream)
logger.debug("Recording successfully downloaded, filepath: %s", temp_file_path)
logger.debug("Initiating OpenAI client")
logger.info("Initiating OpenAI client")
openai_client = openai.OpenAI(
api_key=settings.openai_api_key,
base_url=settings.openai_base_url,
@@ -182,12 +183,11 @@ def process_audio_transcribe_summarize(filename: str, email: str, sub: str):
)
try:
logger.debug("Querying transcription …")
logger.info("Querying transcription …")
with open(temp_file_path, "rb") as audio_file:
transcription = openai_client.audio.transcriptions.create(
model=settings.openai_asr_model, file=audio_file
)
transcription = transcription.text
logger.debug("Transcription: \n %s", transcription)
@@ -252,12 +252,14 @@ def process_audio_transcribe_summarize_v2(
)
temp_file_path = save_audio_stream(audio_file_stream)
logger.debug("Recording successfully downloaded, filepath: %s", temp_file_path)
logger.info("Recording successfully downloaded")
logger.debug("Recording filepath: %s", temp_file_path)
audio_file = File(temp_file_path)
tasks_tracker.track(task_id, {"audio_length": audio_file.info.length})
logger.debug("Initiating OpenAI client")
logger.info("Initiating OpenAI client")
openai_client = openai.OpenAI(
api_key=settings.openai_api_key,
base_url=settings.openai_base_url,
@@ -265,7 +267,7 @@ def process_audio_transcribe_summarize_v2(
)
try:
logger.debug("Querying transcription …")
logger.info("Querying transcription …")
transcription_start_time = time.time()
with open(temp_file_path, "rb") as audio_file:
transcription = openai_client.audio.transcriptions.create(
@@ -279,6 +281,7 @@ def process_audio_transcribe_summarize_v2(
)
},
)
logger.info("Transcription received.")
logger.debug("Transcription: \n %s", transcription)
finally:
if os.path.exists(temp_file_path):