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 9c4d711e1de Added job_clusters as a templated parameter to
CreateDatabricksWorkflowOperator (#45022)
9c4d711e1de is described below
commit 9c4d711e1de68da9faa6ebbcded4eed08d7b9c61
Author: Kunal Bhattacharya <[email protected]>
AuthorDate: Wed Dec 18 19:00:03 2024 +0530
Added job_clusters as a templated parameter to
CreateDatabricksWorkflowOperator (#45022)
---
.../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 6df8e2d025c..f9f91adcb56 100644
---
a/providers/src/airflow/providers/databricks/operators/databricks_workflow.py
+++
b/providers/src/airflow/providers/databricks/operators/databricks_workflow.py
@@ -93,7 +93,7 @@ class _CreateDatabricksWorkflowOperator(BaseOperator):
"""
operator_extra_links = (WorkflowJobRunLink(),
WorkflowJobRepairAllFailedLink())
- template_fields = ("notebook_params",)
+ template_fields = ("notebook_params", "job_clusters")
caller = "_CreateDatabricksWorkflowOperator"
def __init__(
