Catch some errors without exiting

burningmantech · Nov 6, 2023 · 831ea12 · 831ea12
1 parent 87aa544
commit 831ea12
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 5 deletions.
diff --git a/src/transmissions/indexer/_indexer.py b/src/transmissions/indexer/_indexer.py
@@ -293,7 +293,15 @@ async def _addDuration(
         self.log.info(
             "Computing duration for {transmission}", transmission=transmission
         )
-        duration = await deferToThread(self._duration, transmission.path)
+        try:
+            duration = await deferToThread(self._duration, transmission.path)
+        except Exception as e:
+            self.log.error(
+                "Unable to compute duration for "
+                "transmission {transmission}: {error}",
+                transmission=transmission,
+                error=e,
+            )
         await store.setTransmissionDuration(
             eventID=transmission.eventID,
             system=transmission.system,
@@ -328,9 +336,16 @@ async def _addTranscription(
             "Computing transcription for {transmission}",
             transmission=transmission,
         )
-        transcription = await deferToThread(
-            self._transcription, transmission.path
-        )
+        try:
+            transcription = await deferToThread(
+                self._transcription, transmission.path
+            )
+        except Exception as e:
+            self.log.error(
+                "Unable to transcribe transmission {transmission}: {error}",
+                transmission=transmission,
+                error=e,
+            )
         await store.setTransmissionTranscription(
             eventID=transmission.eventID,
             system=transmission.system,

diff --git a/src/transmissions/run/_application.py b/src/transmissions/run/_application.py
@@ -279,7 +279,7 @@ def filterTable(self, row: TransmissionTableRowItems, key: str) -> bool:
         if not transcription:
             return False
 
-        for term in query.split(" "):
+        for term in query.split():
             if term:
                 term = term.lower()
                 if transcription.lower().find(term) != -1: