Added job_clusters as a templated parameter to CreateDatabricksWorkfl…

…owOperator (apache#45022)
VladaZakharova · Dec 18, 2024 · 9c4d711 · 9c4d711
1 parent 553ddf3
commit 9c4d711
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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__(