Skip to content

Commit

Permalink
[AIRFLOW-XXXX] Remove duplication in BaseOperator docstring (#7321)
Browse files Browse the repository at this point in the history
(cherry picked from commit 7f3f666)
  • Loading branch information
zuku1985 authored and potiuk committed Feb 25, 2020
1 parent f56a973 commit c3ce0c7
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions airflow/models/baseoperator.py
Original file line number Diff line number Diff line change
Expand Up @@ -135,10 +135,6 @@ class derived from this one results in the creation of a task object,
only tasks *immediately* downstream of the previous task instance are waited
for; the statuses of any tasks further downstream are ignored.
:type wait_for_downstream: bool
:param queue: which queue to target when running this job. Not
all executors implement queue management, the CeleryExecutor
does support targeting specific queues.
:type queue: str
:param dag: a reference to the dag the task is attached to (if any)
:type dag: airflow.models.DAG
:param priority_weight: priority weight of this task against other task.
Expand Down Expand Up @@ -169,7 +165,9 @@ class derived from this one results in the creation of a task object,
DAGS. Options can be set as string or using the constants defined in
the static class ``airflow.utils.WeightRule``
:type weight_rule: str
:param queue: specifies which task queue to use
:param queue: which queue to target when running this job. Not
all executors implement queue management, the CeleryExecutor
does support targeting specific queues.
:type queue: str
:param pool: the slot pool this task should run in, slot pools are a
way to limit concurrency for certain tasks
Expand Down

0 comments on commit c3ce0c7

Please sign in to comment.