diff --git a/admin/tools/docker/base/Dockerfile b/admin/tools/docker/base/Dockerfile
index 1a28b20391..24b84fb818 100644
--- a/admin/tools/docker/base/Dockerfile
+++ b/admin/tools/docker/base/Dockerfile
@@ -134,7 +134,7 @@ RUN pip3 install \
     ltd-conveyor \
     "sphinx-rtd-theme>=1.2.0rc3" \
     mypy \
-    mysql-connector-python \
+    "mysql-connector-python==8.0.31" \
     numpy \
     pybind11[global] \
     pyyaml \
@@ -230,7 +230,7 @@ RUN pip3 install \
     click \
     deprecated \
     jinja2 \
-    mysql-connector-python \
+    "mysql-connector-python==8.0.31" \
     pyyaml \
     requests \
     sqlalchemy
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."