wip

Author: cameledev

src/backend/core/recording/event/notification.py

@@ -169,7 +169,7 @@ async def _fetch():
                             )
                         return started, ended
             except Exception:
-                logger.warning(
+                logger.exception(
                     "Could not fetch egress info for worker %s", worker_id
                 )
             finally:

src/summary/summary/core/analytics.py

@@ -112,6 +112,8 @@ def create(self, task_id, task_args):
         if self._is_disabled or self.has_task_id(task_id):
             return
 
+        # Positional args mirror process_audio_transcribe_summarize_v2 signature:
+        # owner_id, recording_filename, metadata_filename, email, sub, received_at, ...
         _, filename, _, email, _, received_at, *_ = task_args
 
         start_time = time.time()

src/summary/summary/core/celery_worker.py

@@ -240,8 +240,12 @@ def process_audio_transcribe_summarize_v2(
         recording_end_dt = datetime.fromisoformat(recording_ended_at)
 
     # Assign user names from metadata and transcription
-    metadata = file_service.read_json(metadata_filename)
-    if recording_start_dt is not None and recording_end_dt is not None:
+    try:
+        metadata = file_service.read_json(metadata_filename)
+    except Exception:
+        logger.exception("Failed to read metadata file: %s", metadata_filename)
+        metadata = None
+    if metadata and recording_start_dt is not None and recording_end_dt is not None:
         assignment_result = assign_speakers(
             metadata,
             transcription,

src/summary/summary/core/user_assign.py

@@ -250,13 +250,11 @@ def assign_speakers(
     )
     speaker_timelines = _build_speaker_timelines(transcription)
 
-    logger.info("Info info info")
-    logger.info(metadata)
-    logger.info(recording_start_datetime)
-    logger.info("participant_timelines")
-    logger.info(participant_timelines)
-    logger.info("participant_names")
-    logger.info(participant_names)
+    logger.debug(
+        "Assignment inputs: %d participants, %d speakers",
+        len(participant_timelines),
+        len(speaker_timelines),
+    )
 
     result = AssignmentResult()