raphaelauv opened a new pull request #20411:
URL: https://github.com/apache/airflow/pull/20411
Currently I have to create a dummy task to have the possibility to skip none
task with the BranchOperator
```python
def skip_things() -> str:
if NOTHING == 0:
return "dummy"
elif SOMETHING_WEIRD == 1:
return "task_2"
else:
return "task_3"
branch_task = BranchPythonOperator(
task_id='branch_task',
python_callable=skip_things)
task_2 = ...
task_3 = ...
branch_task >> [DummyOperator(task_id='dummy'), task_2, task_3 ]
```
I would prefer to have a cleaner DAG and not be force to skip at least one
task.
This PR give the possibility to skip none ( zero ) tasks with the
BranchOperator
--
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]
