From 3f7204138a05c8543a0ffd11c0e0d7ef7323d809 Mon Sep 17 00:00:00 2001
From: mtustin-handy <mtustin@handy.com>
Date: Thu, 24 Sep 2015 11:29:50 -0400
Subject: [PATCH] Fix issue https://github.com/airbnb/airflow/issues/459 -
 mysql error 2014

---
 airflow/hooks/dbapi_hook.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/hooks/dbapi_hook.py b/airflow/hooks/dbapi_hook.py
index 82bedbf9b6e7d..422a2be00f9ba 100644
--- 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):