This is an automated email from the ASF dual-hosted git repository. kaxilnaik pushed a commit to branch v3-0-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit d13713eb338af300df74d821f01d281df43eb48b Author: David Blain <[email protected]> AuthorDate: Fri Jul 4 13:52:26 2025 +0200 Allow `DEFAULT_QUEUE` to be configurable from airflow settings in Task SDK (#52786) Co-authored-by: David Blain <[email protected]> (cherry picked from commit c65dc8e09caf6090e8a0e680c2a2cc8861889ca3) --- task-sdk/src/airflow/sdk/definitions/_internal/abstractoperator.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/task-sdk/src/airflow/sdk/definitions/_internal/abstractoperator.py b/task-sdk/src/airflow/sdk/definitions/_internal/abstractoperator.py index ec2fefa0a08..95c8d9d8287 100644 --- a/task-sdk/src/airflow/sdk/definitions/_internal/abstractoperator.py +++ b/task-sdk/src/airflow/sdk/definitions/_internal/abstractoperator.py @@ -30,6 +30,7 @@ from typing import TYPE_CHECKING, Any, ClassVar import methodtools +from airflow.configuration import conf from airflow.sdk.definitions._internal.mixins import DependencyMixin from airflow.sdk.definitions._internal.node import DAGNode from airflow.sdk.definitions._internal.templater import Templater @@ -61,7 +62,7 @@ DEFAULT_PRIORITY_WEIGHT: int = 1 MINIMUM_PRIORITY_WEIGHT: int = -2147483648 MAXIMUM_PRIORITY_WEIGHT: int = 2147483647 DEFAULT_EXECUTOR: str | None = None -DEFAULT_QUEUE: str = "default" +DEFAULT_QUEUE: str = conf.get("operators", "default_queue", "default") DEFAULT_IGNORE_FIRST_DEPENDS_ON_PAST: bool = False DEFAULT_WAIT_FOR_PAST_DEPENDS_BEFORE_SKIPPING: bool = False DEFAULT_RETRIES: int = 0
