diff --git a/relay/application.py b/relay/application.py index de68bc2..dbe464f 100644 --- a/relay/application.py +++ b/relay/application.py @@ -4,6 +4,7 @@ import os import queue import signal import threading +import traceback from aiohttp import web from datetime import datetime, timedelta @@ -175,6 +176,10 @@ class PushWorker(threading.Thread): except queue.Empty: pass + ## make sure an exception doesn't bring down the worker + except Exception: + traceback.print_exc() + await self.client.close()