This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 8dfe7bf5ff Added databricks_conn_id as templated field (#24945)
8dfe7bf5ff is described below

commit 8dfe7bf5ff090a675353a49da21407dffe2fc15e
Author: Sandeep <[email protected]>
AuthorDate: Mon Jul 11 20:17:31 2022 +0530

    Added databricks_conn_id as templated field (#24945)
---
 airflow/providers/databricks/operators/databricks.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/airflow/providers/databricks/operators/databricks.py 
b/airflow/providers/databricks/operators/databricks.py
index 28bdf33226..a63eaa06c1 100644
--- a/airflow/providers/databricks/operators/databricks.py
+++ b/airflow/providers/databricks/operators/databricks.py
@@ -287,7 +287,7 @@ class DatabricksSubmitRunOperator(BaseOperator):
     :param databricks_conn_id: Reference to the :ref:`Databricks connection 
<howto/connection:databricks>`.
         By default and in the common case this will be ``databricks_default``. 
To use
         token based authentication, provide the key ``token`` in the extra 
field for the
-        connection and create the key ``host`` and leave the ``host`` field 
empty.
+        connection and create the key ``host`` and leave the ``host`` field 
empty. (templated)
     :param polling_period_seconds: Controls the rate which we poll for the 
result of
         this run. By default the operator will poll every 30 seconds.
     :param databricks_retry_limit: Amount of times retry if the Databricks 
backend is
@@ -304,7 +304,7 @@ class DatabricksSubmitRunOperator(BaseOperator):
     """
 
     # Used in airflow.models.BaseOperator
-    template_fields: Sequence[str] = ('json',)
+    template_fields: Sequence[str] = ('json', 'databricks_conn_id')
     template_ext: Sequence[str] = ('.json-tpl',)
     # Databricks brand color (blue) under white text
     ui_color = '#1CB1C2'
@@ -560,7 +560,7 @@ class DatabricksRunNowOperator(BaseOperator):
     :param databricks_conn_id: Reference to the :ref:`Databricks connection 
<howto/connection:databricks>`.
         By default and in the common case this will be ``databricks_default``. 
To use
         token based authentication, provide the key ``token`` in the extra 
field for the
-        connection and create the key ``host`` and leave the ``host`` field 
empty.
+        connection and create the key ``host`` and leave the ``host`` field 
empty. (templated)
     :param polling_period_seconds: Controls the rate which we poll for the 
result of
         this run. By default the operator will poll every 30 seconds.
     :param databricks_retry_limit: Amount of times retry if the Databricks 
backend is
@@ -573,7 +573,7 @@ class DatabricksRunNowOperator(BaseOperator):
     """
 
     # Used in airflow.models.BaseOperator
-    template_fields: Sequence[str] = ('json',)
+    template_fields: Sequence[str] = ('json', 'databricks_conn_id')
     template_ext: Sequence[str] = ('.json-tpl',)
     # Databricks brand color (blue) under white text
     ui_color = '#1CB1C2'

Reply via email to