You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by fo...@apache.org on 2018/03/08 12:51:16 UTC

incubator-airflow git commit: [AIRFLOW-2106] SalesForce hook sandbox option

Repository: incubator-airflow
Updated Branches:
  refs/heads/master b8c2cea36 -> 1a0853773


[AIRFLOW-2106] SalesForce hook sandbox option

Cannot pass sandbox argument to sales_force hook preventing sandbox connection.

Closes #3111 from feng-tao/airflow-2106


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/1a085377
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/1a085377
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/1a085377

Branch: refs/heads/master
Commit: 1a08537733d4b964568e7e6eaae4edbe81ba157c
Parents: b8c2cea
Author: Tao feng <tf...@lyft.com>
Authored: Thu Mar 8 13:50:41 2018 +0100
Committer: Fokko Driesprong <fo...@godatadriven.com>
Committed: Thu Mar 8 13:50:44 2018 +0100

----------------------------------------------------------------------
 airflow/contrib/hooks/salesforce_hook.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/1a085377/airflow/contrib/hooks/salesforce_hook.py
----------------------------------------------------------------------
diff --git a/airflow/contrib/hooks/salesforce_hook.py b/airflow/contrib/hooks/salesforce_hook.py
index bf03638..50c60e8 100644
--- a/airflow/contrib/hooks/salesforce_hook.py
+++ b/airflow/contrib/hooks/salesforce_hook.py
@@ -79,7 +79,8 @@ class SalesforceHook(BaseHook, LoggingMixin):
             username=self.connection.login,
             password=self.connection.password,
             security_token=self.extras['security_token'],
-            instance_url=self.connection.host
+            instance_url=self.connection.host,
+            sandbox=self.extras.get('sandbox', False)
         )
         self.sf = sf
         return sf