Merge pull request #13562 from ic4f/dev_sa20_3

Misc. SQLAlchemy 2.0 upgrades
This commit is contained in:
John Chilton
2022-03-20 18:37:17 -04:00
committed by GitHub
14 changed files with 73 additions and 57 deletions
+3 -3
View File
@@ -19,7 +19,7 @@ from sqlalchemy import (
null,
true,
)
from sqlalchemy.orm import eagerload
from sqlalchemy.orm import joinedload
sys.path.insert(1, os.path.abspath(os.path.join(os.path.dirname(__file__), os.pardir, os.pardir, "lib")))
@@ -258,7 +258,7 @@ def purge_histories(app, cutoff_time, remove_from_disk, info_only=False, force_r
histories = (
app.sa_session.query(app.model.History)
.filter(and_(app.model.History.table.c.deleted == true(), app.model.History.update_time < cutoff_time))
.options(eagerload("datasets"))
.options(joinedload("datasets"))
)
else:
histories = (
@@ -270,7 +270,7 @@ def purge_histories(app, cutoff_time, remove_from_disk, info_only=False, force_r
app.model.History.update_time < cutoff_time,
)
)
.options(eagerload("datasets"))
.options(joinedload("datasets"))
)
for history in histories:
log.info("### Processing history id %d (%s)", history.id, unicodify(history.name))
@@ -5,6 +5,7 @@ import os
import sys
from configparser import ConfigParser
from sqlalchemy import text
from sqlalchemy.exc import (
OperationalError,
ProgrammingError,
@@ -38,7 +39,7 @@ def check_db(config: ToolShedAppConfiguration):
try:
if sa_session is not None:
result = sa_session.execute("SELECT version FROM migrate_version").first()
result = sa_session.execute(text("SELECT version FROM migrate_version")).first()
if result[0] >= 2:
sys.exit(database_exists_message)
else: