We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
DEFAULT_QUEUE
1 parent 554fbc6 commit c65dc8eCopy full SHA for c65dc8e
task-sdk/src/airflow/sdk/definitions/_internal/abstractoperator.py
@@ -30,6 +30,7 @@
30
31
import methodtools
32
33
+from airflow.configuration import conf
34
from airflow.sdk.definitions._internal.mixins import DependencyMixin
35
from airflow.sdk.definitions._internal.node import DAGNode
36
from airflow.sdk.definitions._internal.templater import Templater
@@ -61,7 +62,7 @@
61
62
MINIMUM_PRIORITY_WEIGHT: int = -2147483648
63
MAXIMUM_PRIORITY_WEIGHT: int = 2147483647
64
DEFAULT_EXECUTOR: str | None = None
-DEFAULT_QUEUE: str = "default"
65
+DEFAULT_QUEUE: str = conf.get("operators", "default_queue", "default")
66
DEFAULT_IGNORE_FIRST_DEPENDS_ON_PAST: bool = False
67
DEFAULT_WAIT_FOR_PAST_DEPENDS_BEFORE_SKIPPING: bool = False
68
DEFAULT_RETRIES: int = 0
0 commit comments