diff --git a/migratron/command/run_migration.py b/migratron/command/run_migration.py
index adf7d6a..e02337e 100644
--- a/migratron/command/run_migration.py
+++ b/migratron/command/run_migration.py
@@ -247,7 +247,6 @@ def _execute_filename(self, file_content, complete_filename):
                     cursor.fetchall()  # Force non async execution
                 except ResourceClosedError:
                     pass
-                conn.close()
             command = None
         else:
             raise ValueError("Invalid database type")