Skip to content

Commit

Permalink
Branching related additions to docs
Browse files Browse the repository at this point in the history
  • Loading branch information
mistercrunch committed Nov 23, 2015
1 parent a3dacf6 commit 4497b53
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 0 deletions.
2 changes: 2 additions & 0 deletions airflow/operators/python_operator.py
Original file line number Diff line number Diff line change
Expand Up @@ -83,6 +83,8 @@ class BranchPythonOperator(PythonOperator):
Note that using tasks with ``depends_on_past=True`` downstream from
``BranchPythonOperator`` is logically unsound as ``skipped`` status
will invariably lead to block tasks that depend on their past successes.
``skipped`` states propagates where all directly upstream tasks are
``skipped``.
"""
def execute(self, context):
branch = super(BranchPythonOperator, self).execute(context)
Expand Down
6 changes: 6 additions & 0 deletions docs/concepts.rst
Original file line number Diff line number Diff line change
Expand Up @@ -211,6 +211,12 @@ is followed, and all of the other paths are skipped.
The task_id returned by the Python function has to be referencing a task
directly downstream from the BranchPythonOperator task.

Note that using tasks with ``depends_on_past=True`` downstream from
``BranchPythonOperator`` is logically unsound as ``skipped`` status
will invariably lead to block tasks that depend on their past successes.
``skipped`` states propagates where all directly upstream tasks are
``skipped``.


SLAs
''''
Expand Down

0 comments on commit 4497b53

Please sign in to comment.