detect dead DB connections in the dispatcher when reaping jobs

This commit is contained in:
Ryan Petrello
2019-01-22 08:40:26 -05:00
parent 18409f89c5
commit b2442d42a3

View File

@@ -373,6 +373,10 @@ class AutoscalePool(WorkerPool):
# don't use our logger (it accesses the database for configuration)
_, _, tb = sys.exc_info()
traceback.print_tb(tb)
for conn in connections.all():
# If the database connection has a hiccup, re-establish a new
# connection
conn.close_if_unusable_or_obsolete()
def up(self):
if self.full: