From 2fccd81bcdb4866256bd521d24178c9e18ecec30 Mon Sep 17 00:00:00 2001
From: Mathieu Virbel <mat@meltingrocks.com>
Date: Fri, 15 Aug 2025 15:41:23 -0600
Subject: [PATCH] fix: use structlog not logging (#550)

---
 server/reflector/db/search.py      |  4 +---
 server/reflector/db/transcripts.py | 10 ++++------
 2 files changed, 5 insertions(+), 9 deletions(-)

diff --git a/server/reflector/db/search.py b/server/reflector/db/search.py
index 456279d9..93707c75 100644
--- a/server/reflector/db/search.py
+++ b/server/reflector/db/search.py
@@ -1,6 +1,5 @@
 """Search functionality for transcripts and other entities."""
 
-import logging
 from datetime import datetime
 from io import StringIO
 from typing import Annotated, Any, Dict
@@ -12,8 +11,7 @@ from pydantic import BaseModel, Field, constr, field_serializer
 from reflector.db import get_database
 from reflector.db.transcripts import SourceKind, transcripts
 from reflector.db.utils import is_postgresql
-
-logger = logging.getLogger(__name__)
+from reflector.logger import logger
 
 DEFAULT_SEARCH_LIMIT = 20
 SNIPPET_CONTEXT_LENGTH = 50  # Characters before/after match to include
diff --git a/server/reflector/db/transcripts.py b/server/reflector/db/transcripts.py
index 4310183b..7d3d6d1c 100644
--- a/server/reflector/db/transcripts.py
+++ b/server/reflector/db/transcripts.py
@@ -1,6 +1,5 @@
 import enum
 import json
-import logging
 import os
 import shutil
 from contextlib import asynccontextmanager
@@ -19,14 +18,13 @@ from reflector.db import get_database, metadata
 from reflector.db.recordings import recordings_controller
 from reflector.db.rooms import rooms
 from reflector.db.utils import is_postgresql
+from reflector.logger import logger
 from reflector.processors.types import Word as ProcessorWord
 from reflector.settings import settings
 from reflector.storage import get_recordings_storage, get_transcripts_storage
 from reflector.utils import generate_uuid4
 from reflector.utils.webvtt import topics_to_webvtt
 
-logger = logging.getLogger(__name__)
-
 
 class SourceKind(enum.StrEnum):
     ROOM = enum.auto()
@@ -602,7 +600,7 @@ class TranscriptController:
             except Exception as e:
                 logger.warning(
                     "Failed to delete transcript audio from storage",
-                    error=str(e),
+                    exc_info=e,
                     transcript_id=transcript.id,
                 )
         transcript.unlink()
@@ -617,14 +615,14 @@ class TranscriptController:
                     except Exception as e:
                         logger.warning(
                             "Failed to delete recording object from S3",
-                            error=str(e),
+                            exc_info=e,
                             recording_id=transcript.recording_id,
                         )
                     await recordings_controller.remove_by_id(transcript.recording_id)
             except Exception as e:
                 logger.warning(
                     "Failed to delete recording row",
-                    error=str(e),
+                    exc_info=e,
                     recording_id=transcript.recording_id,
                 )
         query = transcripts.delete().where(transcripts.c.id == transcript_id)