From e7e655fde3c29742149d047028cbb21aecba86ed Mon Sep 17 00:00:00 2001 From: biellls Date: Mon, 2 May 2016 15:58:12 +0200 Subject: [PATCH] Fixed MsSql autocommit bug --- airflow/hooks/mssql_hook.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/airflow/hooks/mssql_hook.py b/airflow/hooks/mssql_hook.py index d572d2113202d..2b6610dab0a8d 100644 --- a/airflow/hooks/mssql_hook.py +++ b/airflow/hooks/mssql_hook.py @@ -22,4 +22,7 @@ def get_conn(self): conn.login, conn.password, conn.schema) - return conn \ No newline at end of file + return conn + + def set_autocommit(self, conn, autocommit): + conn.autocommit(autocommit)