moomindani commented on issue #64195:
URL: https://github.com/apache/airflow/issues/64195#issuecomment-4139570447
**Tested `databricks: 7.12.0rc1`** — fix: Map Airflow trigger_rule to
Databricks run_if in DatabricksWorkflowTaskGroup (#63420)
I am the original author of #63420.
**Environment:** Airflow 3.2.0dev · Python 3.11 · macOS (RC tag
`providers-databricks/7.12.0rc1`) · Databricks workspace (AWS, ap-northeast-1)
**End-to-end DAG test** (real Databricks workspace via `airflow dags test`):
```python
with DatabricksWorkflowTaskGroup(
group_id="test_trigger_rule_wf",
databricks_conn_id=DATABRICKS_CONN_ID,
job_clusters=JOB_CLUSTERS,
) as wf:
task_a = DatabricksNotebookOperator(task_id="task_a", ...) # default
trigger_rule
task_b = DatabricksNotebookOperator(task_id="task_b",
trigger_rule="one_success", ...)
task_c = DatabricksNotebookOperator(task_id="task_c",
trigger_rule="all_done", ...)
task_a >> [task_b, task_c]
```
**Result:** Job created on Databricks with correct `run_if` values in the
workflow JSON:
- `task_a` (`all_success`): no `run_if` — ✅ uses Databricks default
- `task_b` (`one_success`): `"run_if": "AT_LEAST_ONE_SUCCESS"` — ✅
- `task_c` (`all_done`): `"run_if": "ALL_DONE"` — ✅
```
DagRun Finished: state=success
```
All tasks ran successfully on Databricks. Fix confirmed end-to-end. ✅ LGTM
for release.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
