BranchPythonOperator.execute cannot be called outside TaskInstance!

[tomplus]

Apache Airflow version

2.10.5

If "Other Airflow 2 version" selected, which one?

No response

What happened?

For some reason BranchPythonOperator reports warning:

[2025-03-07, 18:13:18 UTC] {local_task_job_runner.py:123} ▶ Pre task execution logs
[2025-03-07, 18:13:19 UTC] {baseoperator.py:424} WARNING - BranchPythonOperator.execute cannot be called outside TaskInstance!
[2025-03-07, 18:13:19 UTC] {python.py:240} INFO - Done. Returned value was: branch_b
[2025-03-07, 18:13:19 UTC] {branch.py:38} INFO - Branch into branch_b
[2025-03-07, 18:13:19 UTC] {skipmixin.py:233} INFO - Following branch ('branch_b',)
[2025-03-07, 18:13:19 UTC] {skipmixin.py:281} INFO - Skipping tasks [('branch_c', -1), ('branch_d', -1), ('branch_a', -1)]
[2025-03-07, 18:13:19 UTC] {taskinstance.py:341} ▶ Post task execution logs

it's from example_branch_operator.

What you think should happen instead?

No response

How to reproduce

Run example 'example_branch_operator'.

Operating System

Ubuntu 22

Versions of Apache Airflow Providers

It's a fresh installation (pip install airflow)

Deployment

Virtualenv installation

Deployment details

No response

Anything else?

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[boring-cyborg]

Thanks for opening your first issue here! Be sure to follow the issue template! If you are willing to raise PR to address this issue please do so, no need to wait for approval.

[insomnes]

There was similar issue, where it was mentioned that it's not fixed yet:

#45498 (comment)

I've also seen the same behaviour on current main branch with TriggerDagRunOpertator

[insomnes]

I think I was able to reproduce reliably, identify, and fix this bug in:

#47552

But the code behind all of this is tricky so I am not 100% sure.