From 5cc67aba1572f7e0fb63e0436e5b786f55dd3745 Mon Sep 17 00:00:00 2001
From: Jakob Ketterl <jakob.ketterl@gmx.de>
Date: Fri, 23 Aug 2019 22:32:46 +0200
Subject: [PATCH] handle execptions during decode to avoid worker drain

---
 owrx/wsjt.py | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/owrx/wsjt.py b/owrx/wsjt.py
index 34f7f4f..5c6ea8b 100644
--- a/owrx/wsjt.py
+++ b/owrx/wsjt.py
@@ -27,8 +27,11 @@ class WsjtQueueWorker(threading.Thread):
     def run(self) -> None:
         while self.doRun:
             (processor, file) = self.queue.get()
-            logger.debug("processing file %s", file)
-            processor.decode(file)
+            try:
+                logger.debug("processing file %s", file)
+                processor.decode(file)
+            except Exception:
+                logger.exception("failed to decode job")
             self.queue.task_done()