How Do I Execute Conditional Branching? about airflow HOT 5 CLOSED

I see the case for a branch operator, though we tend to wire things down different path by using an attribute of the data, and an empty batch typically never happens except if there is a problem.

An easy implementation would be to essentially derive the PythonOperator into a BranchPythonOperator, and have the assumption that the python_callable returns the name of the branch to take, namely the task_id of the direct downstream task to follow. Then this operator would set a failed status on all the directly downstream task_ids not returned.

from airflow.

I wrote a quick sketch of what it may look like in this branch https://github.com/airbnb/airflow/compare/branch_python_operator?expand=1 but haven't tested it, let me know what you think.

from airflow.

#96

from airflow.

Folks, when are you planning your next release. I would like to use this in our staging environment and that is currently deployed using "pip"

from airflow.

v1.2.0 is out!
https://pypi.python.org/pypi/airflow

I pushed the new version of the docs to http://pythonhosted.org/airflow/ also

from airflow.