Clarify the function of wait_for_downstream

This commit is contained in:
Marty Woodlee 2015-06-25 12:14:56 -05:00
Родитель f16381922c
Коммит 6ee8c37346
1 изменённых файлов: 5 добавлений и 5 удалений

Просмотреть файл

@ -962,11 +962,11 @@ class BaseOperator(object):
sequentially while relying on the previous task's schedule to
succeed. The task instance for the start_date is allowed to run.
:type depends_on_past: bool
:param wait_for_downstream: when set to true, the task instances
of task X will wait for the dependencies of the previous instance
of task X to finish before it moves on the to next schedule.
This is useful if the different instances of a task X alter
the same asset, and this asset is used by the dependencies of task X.
:param wait_for_downstream: when set to true, an instance of task
X will wait for the dependents of the previous instance of task X
to finish successfully before it runs. This is useful if the
different instances of a task X alter the same asset, and this asset
is used by the dependencies of task X.
:type wait_for_downstream: bool
:param queue: which queue to target when running this job. Not
all executors implement queue management, the CeleryExecutor