Skip to content
Merged
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,6 +28,11 @@
from urllib3.exceptions import ReadTimeoutError

from airflow.exceptions import AirflowException
from airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types import (
ADOPTED,
ALL_NAMESPACES,
POD_EXECUTOR_DONE_KEY,
)
from airflow.providers.cncf.kubernetes.kube_client import get_kube_client
from airflow.providers.cncf.kubernetes.kubernetes_helper_functions import (
annotations_for_logging_task_metadata,
Expand All @@ -39,19 +44,6 @@
from airflow.utils.singleton import Singleton
from airflow.utils.state import TaskInstanceState

try:
from airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types import (
ADOPTED,
ALL_NAMESPACES,
POD_EXECUTOR_DONE_KEY,
)
except ImportError:
# avoid failing import when Airflow pre 2.7 is installed
from airflow.kubernetes.kubernetes_executor_types import ( # type: ignore[no-redef]
ALL_NAMESPACES,
POD_EXECUTOR_DONE_KEY,
)

if TYPE_CHECKING:
from kubernetes.client import Configuration, models as k8s

Expand Down