diff --git a/superset/models/core.py b/superset/models/core.py index 007049827b..9264fcfe36 100644 --- a/superset/models/core.py +++ b/superset/models/core.py @@ -738,8 +738,12 @@ class Database(Model, AuditMixinNullable, ImportMixin): with closing(engine.raw_connection()) as conn: with closing(conn.cursor()) as cursor: - for sql in sqls: + for sql in sqls[:-1]: self.db_engine_spec.execute(cursor, sql) + cursor.fetchall() + + self.db_engine_spec.execute(cursor, sqls[-1]) + df = pd.DataFrame.from_records( data=list(cursor.fetchall()), columns=[col_desc[0] for col_desc in cursor.description],