Merge pull request #517 from jzelinskie/fixmysqlssl

close connections after getting queue metrics

data/queue.py

@@ -1,6 +1,7 @@
 from datetime import datetime, timedelta
 
-from data.database import QueueItem, db, db_for_update
+from app import app
+from data.database import QueueItem, db, db_for_update, UseThenDisconnect
 from util.morecollections import AttrDict
 
 
@@ -68,6 +69,7 @@ class WorkQueue(object):
     return db_for_update(QueueItem.select().where(QueueItem.id == queue_id)).get()
 
   def get_metrics(self, require_transaction=True):
+    with UseThenDisconnect(app.config):
       guard = self._transaction_factory(db) if require_transaction else NoopWith()
       with guard:
         now = datetime.utcnow()