Fixed MsSql autocommit bug

apache · May 2, 2016 · e7e655f · e7e655f
1 parent 03aa500
commit e7e655f
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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
+        return conn
+
+    def set_autocommit(self, conn, autocommit):
+        conn.autocommit(autocommit)