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

…-patch Fix issue #459 - mysql error 2014
apache · Sep 24, 2015 · 41695a1 · 41695a1
2 parents 678987e + 3f72041
commit 41695a1
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):