Close session after execute. (#2677)

This commit is contained in:
Johann Kellerman 2016-07-31 19:10:30 +02:00 committed by Paulus Schoutsen
parent a81a8c2bdf
commit 74f284d2d7

View File

@ -58,6 +58,7 @@ def execute(q):
This method also retries a few times in the case of stale connections. This method also retries a few times in the case of stale connections.
""" """
import sqlalchemy.exc import sqlalchemy.exc
try:
for _ in range(0, RETRIES): for _ in range(0, RETRIES):
try: try:
return [ return [
@ -66,6 +67,8 @@ def execute(q):
if row is not None] if row is not None]
except sqlalchemy.exc.SQLAlchemyError as e: except sqlalchemy.exc.SQLAlchemyError as e:
log_error(e, retry_wait=QUERY_RETRY_WAIT, rollback=True) log_error(e, retry_wait=QUERY_RETRY_WAIT, rollback=True)
finally:
Session().close()
return [] return []