[AIRFLOW-XXXX] Remove duplication in BaseOperator docstring (#7321)

apache · Feb 22, 2020 · 7f3f666 · 7f3f666 · MichaelChirico · Apr 7, 2020
1 parent be0501b
commit 7f3f666
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/airflow/models/baseoperator.py b/airflow/models/baseoperator.py
@@ -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.
@@ -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