[AIRFLOW-775] Fix autocommit settings with Jdbc hook

Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/97954e21
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/97954e21
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/97954e21

Branch: refs/heads/master
Commit: 97954e21229982f580f18732c5018714f7e51087
Parents: a33b29c
Author: Arthur Wiedmer <[email protected]>
Authored: Mon Apr 23 09:42:21 2018 -0700
Committer: Arthur Wiedmer <[email protected]>
Committed: Mon Apr 23 09:52:08 2018 -0700

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


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/97954e21/airflow/hooks/jdbc_hook.py
----------------------------------------------------------------------
diff --git a/airflow/hooks/jdbc_hook.py b/airflow/hooks/jdbc_hook.py
index b76e80d..8f0cd67 100644
--- a/airflow/hooks/jdbc_hook.py
+++ b/airflow/hooks/jdbc_hook.py
@@ -58,4 +58,4 @@ class JdbcHook(DbApiHook):
         :param conn: The connection
         :return:
         """
-        conn.jconn.autocommit = autocommit
+        conn.jconn.setAutoCommit(autocommit)

Reply via email to