Fetch any result rows present after executing migration statements

lsst · Feb 1, 2023 · 3a6a9cc · 3a6a9cc
1 parent 857ab7d
commit 3a6a9cc
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/schema/python/schemaMigMgr.py b/src/schema/python/schemaMigMgr.py
@@ -345,7 +345,8 @@ def apply_migrations(self, migrations: List[Migration]) -> Optional[Version]:
                 _log.debug(f"Migration statement: {stmt}")
                 if stmt:
                     for result in cursor.execute(stmt, multi=True):
-                        pass
+                        if result.with_rows:
+                            result.fetchall()
                 else:
                     _log.warn(
                         "Migration statement was empty, nothing to execute."