shubhgurav0590 opened a new pull request, #67369:
URL: https://github.com/apache/airflow/pull/67369
Closes #51598
## Problem
When using DatabricksWorkflowTaskGroup, the internal launch task
ignored upstream task dependencies and executed immediately at DAG
start, regardless of trigger_rule configuration.
## Fix
Added `create_databricks_workflow_task.set_upstream(root_task)` in
the `__exit__` method so the launch task correctly waits for all
upstream dependencies before executing.
## Changes
- One-line fix in `databricks_workflow.py`
- Added unit test `test_launch_task_waits_for_upstream_tasks`
validating that launch task correctly registers upstream task IDs
## Testing
Unit test added in `test_databricks_workflow.py` covering the
external upstream dependency scenario from issue #51598.
## Note on DAG Graph Screenshots
Previous PR #53559 was asked for before/after DAG graph screenshots.
I am setting up Breeze locally to provide these — will add within
24 hours.
--
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]
