From 3a6a9cce9175b7ca66132fad0024700d94823c3b Mon Sep 17 00:00:00 2001
From: Fritz Mueller <fritzm@slac.stanford.edu>
Date: Wed, 1 Feb 2023 05:38:31 +0000
Subject: [PATCH] Fetch any result rows present after executing migration
 statements

---
 src/schema/python/schemaMigMgr.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/schema/python/schemaMigMgr.py b/src/schema/python/schemaMigMgr.py
index b60a5d297b..3b9d89af79 100644
--- 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."