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)