Repository: incubator-airflow
Updated Branches:
  refs/heads/master ac5954d7f -> ab81767d7


[AIRFLOW-2578] Add option to use proxies in JiraHook

Closes #3480 from arashrai/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/ab81767d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/ab81767d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/ab81767d

Branch: refs/heads/master
Commit: ab81767d7504bc3016786780902d8c3997e37f64
Parents: ac5954d
Author: arash-rai <[email protected]>
Authored: Fri Jun 8 11:50:05 2018 -0700
Committer: Alex Guziel <[email protected]>
Committed: Fri Jun 8 11:50:05 2018 -0700

----------------------------------------------------------------------
 airflow/contrib/hooks/jira_hook.py | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/ab81767d/airflow/contrib/hooks/jira_hook.py
----------------------------------------------------------------------
diff --git a/airflow/contrib/hooks/jira_hook.py 
b/airflow/contrib/hooks/jira_hook.py
index 449b6e5..c6806d9 100644
--- a/airflow/contrib/hooks/jira_hook.py
+++ b/airflow/contrib/hooks/jira_hook.py
@@ -32,9 +32,11 @@ class JiraHook(BaseHook, LoggingMixin):
     :type jira_conn_id: string
     """
     def __init__(self,
-                 jira_conn_id='jira_default'):
+                 jira_conn_id='jira_default',
+                 proxies=None):
         super(JiraHook, self).__init__(jira_conn_id)
         self.jira_conn_id = jira_conn_id
+        self.proxies = proxies
         self.client = None
         self.get_conn()
 
@@ -73,7 +75,8 @@ class JiraHook(BaseHook, LoggingMixin):
                                        options=extra_options,
                                        basic_auth=(conn.login, conn.password),
                                        get_server_info=get_server_info,
-                                       validate=validate)
+                                       validate=validate,
+                                       proxies=self.proxies)
                 except JIRAError as jira_error:
                     raise AirflowException('Failed to create jira client, jira 
error: %s'
                                            % str(jira_error))

Reply via email to