Make sure we get no tracebacks if we shutdown early

This commit is contained in:
cncfanatics
2010-10-25 09:36:12 +02:00
parent 4d5b2920f3
commit 2436b21867

View File

@@ -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))