Skip to content
This repository has been archived by the owner on May 22, 2021. It is now read-only.

Commit

Permalink
[AIRFLOW-XXXX] Remove duplication in BaseOperator docstring (apache#7321
Browse files Browse the repository at this point in the history
)
  • Loading branch information
zuku1985 authored and galuszkak committed Mar 5, 2020
1 parent 719ef70 commit 169aadf
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions airflow/models/baseoperator.py
Expand Up @@ -139,10 +139,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 @@ -173,7 +169,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 169aadf

Please sign in to comment.