Merge pull request #1 from mtustin-handy/mtustin-handy-mysql-commit-p…

…atch Fix issue apache#459 - mysql error 2014
mtustin-handy · Sep 24, 2015 · 83c231f · 83c231f
2 parents 70b342f + 3f72041
commit 83c231f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/hooks/dbapi_hook.py b/airflow/hooks/dbapi_hook.py
@@ -97,8 +97,8 @@ def run(self, sql, autocommit=False, parameters=None):
         cur = conn.cursor()
         for s in sql:
             cur.execute(s, parameters)
-        conn.commit()
         cur.close()
+        conn.commit()
         conn.close()
 
     def set_autocommit(self, conn, autocommit):