improve error handling for thread-based processes.

opensanctions · Jun 5, 2023 · 0235dec · 0235dec
1 parent cbd1f6c
commit 0235dec
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/yente/data/__init__.py b/yente/data/__init__.py
@@ -22,7 +22,10 @@ async def refresh_catalog() -> None:
 
     async def update_in_thread() -> None:
         log.info("Refreshing manifest/catalog...", catalog=Catalog.instance)
-        Catalog.instance = await Catalog.load()
+        try:
+            Catalog.instance = await Catalog.load()
+        except (Exception, KeyboardInterrupt) as exc:
+            log.exception("Metadata fetch error: %s" % exc)
 
     thread = threading.Thread(
         target=asyncio.run,

diff --git a/yente/search/indexer.py b/yente/search/indexer.py
@@ -173,7 +173,10 @@ async def update_index(force: bool = False) -> bool:
 
 def update_index_threaded(force: bool = False) -> None:
     async def update_in_thread() -> None:
-        await update_index(force=force)
+        try:
+            await update_index(force=force)
+        except (Exception, KeyboardInterrupt) as exc:
+            log.exception("Index update error: %s" % exc)
 
     thread = threading.Thread(
         target=asyncio.run,