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 fff6f7ffc59 Revert "Revert "Added job_clusters as a templated
parameter to CreateDatabric…" (#45066)
fff6f7ffc59 is described below
commit fff6f7ffc596361e2182d30c85fede2cdf0b6977
Author: Kunal Bhattacharya <[email protected]>
AuthorDate: Fri Feb 7 00:58:19 2025 +0530
Revert "Revert "Added job_clusters as a templated parameter to
CreateDatabric…" (#45066)
This reverts commit 09d8a803ca3f76d8598e7eeeb86397cf1cd4076d.
Co-authored-by: Amogh Desai <[email protected]>
---
.../src/airflow/providers/databricks/operators/databricks_workflow.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/providers/src/airflow/providers/databricks/operators/databricks_workflow.py
b/providers/src/airflow/providers/databricks/operators/databricks_workflow.py
index d185d6d30cd..12ea0792f00 100644
---
a/providers/src/airflow/providers/databricks/operators/databricks_workflow.py
+++
b/providers/src/airflow/providers/databricks/operators/databricks_workflow.py
@@ -95,7 +95,7 @@ class _CreateDatabricksWorkflowOperator(BaseOperator):
"""
operator_extra_links = (WorkflowJobRunLink(),
WorkflowJobRepairAllFailedLink())
- template_fields = ("notebook_params",)
+ template_fields = ("notebook_params", "job_clusters")
caller = "_CreateDatabricksWorkflowOperator"
def __init__(
