You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by cr...@apache.org on 2016/06/28 22:17:11 UTC
incubator-airflow git commit: [AIRFLOW-281] Add port to mssql_hook
Repository: incubator-airflow
Updated Branches:
refs/heads/master d6d3f5367 -> be6766a6a
[AIRFLOW-281] Add port to mssql_hook
Closes #1626 from lukem-ow/master
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/be6766a6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/be6766a6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/be6766a6
Branch: refs/heads/master
Commit: be6766a6a87f7b131c0cbe404c0ce45dbaed0cd7
Parents: d6d3f53
Author: luke.maycock <lu...@bluesmithis.com>
Authored: Tue Jun 28 15:16:34 2016 -0700
Committer: Chris Riccomini <ch...@wepay.com>
Committed: Tue Jun 28 15:16:40 2016 -0700
----------------------------------------------------------------------
airflow/hooks/mssql_hook.py | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/be6766a6/airflow/hooks/mssql_hook.py
----------------------------------------------------------------------
diff --git a/airflow/hooks/mssql_hook.py b/airflow/hooks/mssql_hook.py
index ae9d971..1450967 100644
--- a/airflow/hooks/mssql_hook.py
+++ b/airflow/hooks/mssql_hook.py
@@ -32,10 +32,11 @@ class MsSqlHook(DbApiHook):
"""
conn = self.get_connection(self.mssql_conn_id)
conn = pymssql.connect(
- conn.host,
- conn.login,
- conn.password,
- conn.schema)
+ server=conn.host,
+ user=conn.login,
+ password=conn.password,
+ database=conn.schema,
+ port=conn.port)
return conn
def set_autocommit(self, conn, autocommit):