Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@
from botocore.exceptions import ClientError, NoCredentialsError
from semver import VersionInfo

from airflow.configuration import conf
from airflow.executors.base_executor import BaseExecutor
from airflow.models import TaskInstance
from airflow.models.taskinstancekey import TaskInstanceKey
Expand All @@ -43,7 +42,7 @@
CONFIG_GROUP_NAME,
AllBatchConfigKeys,
)
from airflow.providers.common.compat.sdk import AirflowException
from airflow.providers.common.compat.sdk import AirflowException, conf
from airflow.utils.helpers import convert_camel_to_snake
from airflow.utils.state import State
from airflow.version import version as airflow_version_str
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@
AirflowOptionalProviderFeatureException,
BaseOperator,
BaseOperatorLink,
conf,
)
from airflow.providers.common.compat.version_compat import AIRFLOW_V_3_1_PLUS

Expand Down Expand Up @@ -65,8 +66,6 @@ def get_link(
return ""
from urllib.parse import urlparse

from airflow.configuration import conf

base_url = conf.get("api", "base_url", fallback="/")
if base_url.startswith(("http://", "https://")):
base_path = urlparse(base_url).path.rstrip("/")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@

from airflow.api_fastapi.auth.managers.models.resource_details import DagAccessEntity
from airflow.api_fastapi.core_api.security import requires_access_dag
from airflow.configuration import conf
from airflow.models.taskinstance import TaskInstance as TI
from airflow.models.xcom import XComModel
from airflow.plugins_manager import AirflowPlugin
Expand All @@ -46,6 +45,7 @@
HumanFeedbackRequest,
SessionStatus,
)
from airflow.providers.common.compat.sdk import conf
from airflow.utils.session import create_session
from airflow.utils.state import TaskInstanceState

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,12 +43,7 @@

from airflow.api_fastapi.common.types import MenuItem
from airflow.cli.cli_config import CLICommand

try:
from airflow.providers.common.compat.sdk import AirflowException, conf
except ModuleNotFoundError:
from airflow.configuration import conf
from airflow.exceptions import AirflowException
from airflow.providers.common.compat.sdk import AirflowException, conf
from airflow.providers.keycloak.auth_manager.cache import single_flight
from airflow.providers.keycloak.auth_manager.constants import (
CONF_CLIENT_ID_KEY,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,12 @@
from collections.abc import Sequence
from typing import TYPE_CHECKING, Any

from airflow.configuration import conf
from airflow.providers.common.compat.sdk import AirflowException, BaseOperator, BaseOperatorLink
from airflow.providers.common.compat.sdk import (
AirflowException,
BaseOperator,
BaseOperatorLink,
conf,
)
from airflow.providers.microsoft.azure.hooks.powerbi import PowerBIHook
from airflow.providers.microsoft.azure.triggers.powerbi import (
PowerBIDatasetListTrigger,
Expand Down
Loading