diff --git a/service/market.py b/service/market.py index 51f5c17df..dfacfadba 100644 --- a/service/market.py +++ b/service/market.py @@ -45,7 +45,10 @@ class PriceWorkerThread(threading.Thread): except: pass finally: - queue.task_done() + try: + queue.task_done() + except: + pass def trigger(self, prices, callbacks): self.queue.put((callbacks, prices))