This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new a58904349c0 Remove deprecation in Edge for DEFAULT_QUEUE (#52954)
a58904349c0 is described below
commit a58904349c00bc2825d77c55d66a63d92c09fec0
Author: Jens Scheffler <[email protected]>
AuthorDate: Sun Jul 6 21:15:04 2025 +0200
Remove deprecation in Edge for DEFAULT_QUEUE (#52954)
---
.../edge3/src/airflow/providers/edge3/executors/edge_executor.py | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
diff --git
a/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py
b/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py
index 19e99a45725..de3be5e384a 100644
--- a/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py
+++ b/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py
@@ -30,11 +30,6 @@ from sqlalchemy.orm import Session
from airflow.cli.cli_config import GroupCommand
from airflow.configuration import conf
from airflow.executors.base_executor import BaseExecutor
-
-try:
- from airflow.models.abstractoperator import DEFAULT_QUEUE
-except (ImportError, AttributeError):
- from airflow.sdk.definitions._internal.abstractoperator import
DEFAULT_QUEUE
from airflow.models.taskinstance import TaskInstance, TaskInstanceState
from airflow.providers.edge3.cli.edge_command import EDGE_COMMANDS
from airflow.providers.edge3.models.edge_job import EdgeJobModel
@@ -59,6 +54,7 @@ if TYPE_CHECKING:
TaskTuple = tuple[TaskInstanceKey, CommandType, str | None, Any | None]
PARALLELISM: int = conf.getint("core", "PARALLELISM")
+DEFAULT_QUEUE: str = conf.get_mandatory_value("operators", "default_queue")
class EdgeExecutor(BaseExecutor):
