ramitkataria opened a new issue, #48473: URL: https://github.com/apache/airflow/issues/48473
### Apache Airflow version main (development) ### If "Other Airflow 2 version" selected, which one? _No response_ ### What happened? These example DAGs for branch operators fail when the DAG is manually triggered: - The dag `example_branch_datetime_operator_3` in `example_branch_datetime_operator.py` fails when the task `datetime_branch` fails with this stack trace: ``` [2025-03-27, 20:59:40] INFO - DAG bundles loaded: dags-folder: source="***.dag_processing.bundles.manager.DagBundlesManager" [2025-0[3](http://localhost:28080/dags/example_branch_datetime_operator_3/runs/manual__2025-03-27T20:59:40.510906+00:00_LdHU1Uhe/tasks/datetime_branch?try_number=1#3)-27, 20:59:40] INFO - Filling up the DagBag from /files/dags/example_branch_datetime_operator.py: source="***.models.dagbag.DagBag" [2025-03-27, 20:59:[4](http://localhost:28080/dags/example_branch_datetime_operator_3/runs/manual__2025-03-27T20:59:40.510906+00:00_LdHU1Uhe/tasks/datetime_branch?try_number=1#4)0] ERROR - Task failed with exception: source="task" KeyError: 'logical_date' File "/opt/***/task-sdk/src/***/sdk/execution_time/task_runner.py", line 646 in run File "/opt/***/task-sdk/src/***/sdk/execution_time/task_runner.py", line 903 in _execute_task File "/opt/***/task-sdk/src/***/sdk/definitions/baseoperator.py", line 380 in wrapper File "/opt/***/providers/standard/src/***/providers/standard/operators/branch.py", line 105 in execute File "/opt/***/providers/standard/src/***/providers/standard/operators/datetime.py", line 80 in choose_branch ``` - The dag `example_branch_dop_operator_v3` fails when the task `should_run` fails with this stack trace: ``` [2025-03-27, 21:02:23] INFO - DAG bundles loaded: dags-folder: source="***.dag_processing.bundles.manager.DagBundlesManager" [2025-0[3](http://localhost:28080/dags/example_branch_dop_operator_v3/runs/manual__2025-03-27T21:02:22.741244+00:00_QDv3CMdV/tasks/should_run?try_number=1#3)-27, 21:02:23] INFO - Filling up the DagBag from /files/dags/example_branch_python_dop_operator_3.py: source="***.models.dagbag.DagBag" [2025-03-27, 21:02:23] ERROR - Task failed with exception: source="task" KeyError: 'logical_date' File "/opt/***/task-sdk/src/***/sdk/execution_time/task_runner.py", line 6[4](http://localhost:28080/dags/example_branch_dop_operator_v3/runs/manual__2025-03-27T21:02:22.741244+00:00_QDv3CMdV/tasks/should_run?try_number=1#4)6 in run File "/opt/***/task-sdk/src/***/sdk/execution_time/task_runner.py", line 903 in _execute_task File "/opt/***/task-sdk/src/***/sdk/definitions/baseoperator.py", line 380 in wrapper File "/opt/***/***-core/src/***/decorators/base.py", line 252 in execute File "/opt/***/task-sdk/src/***/sdk/definitions/baseoperator.py", line 380 in wrapper File "/opt/***/providers/standard/src/***/providers/standard/operators/python.py", line 255 in execute File "/opt/***/task-sdk/src/***/sdk/definitions/baseoperator.py", line 380 in wrapper File "/opt/***/providers/standard/src/***/providers/standard/operators/python.py", line 212 in execute File "/opt/***/providers/standard/src/***/providers/standard/operators/python.py", line 235 in execute_callable File "/opt/***/task-sdk/src/***/sdk/execution_time/callback_runner.py", line 81 in run File "/files/dags/example_branch_python_dop_operator_3.py", line 40 in should_run ``` ### What you think should happen instead? These tasks are not supposed to fail just like what happens in scheduled runs. They are failing because of `KeyError: 'logical_date'` ### How to reproduce - Copy example DAGs in files `example_branch_python_dop_operator_3.py` and `example_branch_datetime_operator` to your dags directory - Enable DAGs `example_branch_datetime_operator_3` and ` example_branch_dop_operator_v3` - Trigger a DAG run in each of them ### Operating System macOS 15.3.2 ### Versions of Apache Airflow Providers Main branch, commit `64aa6fea179926016630ca94ac8421d2e5692997` ### Deployment Other ### Deployment details Using breeze with command: `breeze start-airflow --backend postgres -f --python 3.9` ### Anything else? Problem occurs every time ### Are you willing to submit PR? - [x] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md) -- 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]
