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 <luke.mayc...@bluesmithis.com> Authored: Tue Jun 28 15:16:34 2016 -0700 Committer: Chris Riccomini <chr...@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):