diff options
Diffstat (limited to 'lib/sqlalchemy/dialects/postgresql/provision.py')
| -rw-r--r-- | lib/sqlalchemy/dialects/postgresql/provision.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/lib/sqlalchemy/dialects/postgresql/provision.py b/lib/sqlalchemy/dialects/postgresql/provision.py index 68a01e483..289dda4b6 100644 --- a/lib/sqlalchemy/dialects/postgresql/provision.py +++ b/lib/sqlalchemy/dialects/postgresql/provision.py @@ -88,7 +88,9 @@ def _postgresql_set_default_schema_on_connection( @drop_all_schema_objects_pre_tables.for_db("postgresql") def drop_all_schema_objects_pre_tables(cfg, eng): with eng.connect().execution_options(isolation_level="AUTOCOMMIT") as conn: - for xid in conn.execute("select gid from pg_prepared_xacts").scalars(): + for xid in conn.exec_driver_sql( + "select gid from pg_prepared_xacts" + ).scalars(): conn.execute("ROLLBACK PREPARED '%s'" % xid) |