Ensure that if a @hook.singlethread hook throws, we keep running it

This commit is contained in:
Jim Porter 2012-08-24 15:31:38 -05:00
parent 9cd121bd2e
commit 508dc11cbf
1 changed files with 4 additions and 1 deletions

View File

@ -102,7 +102,10 @@ class Handler(object):
db_conns[input.conn] = db
input.db = db
run(self.func, input)
try:
run(self.func, input)
except:
traceback.print_exc()
def stop(self):
self.input_queue.put(StopIteration)