• Home
• Index

Index

_

__slots__ (airflow.providers.cncf.kubernetes.backcompat.pod.Port attribute) (airflow.providers.cncf.kubernetes.backcompat.pod.Resources attribute) (airflow.providers.cncf.kubernetes.backcompat.volume_mount.VolumeMount attribute) _convert_from_dict() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) _convert_kube_model_object() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) _convert_to_snake_case() (airflow.providers.cncf.kubernetes.backcompat.volume.Volume static method) _exec_pod_command() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method)

_extract_xcom() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method) _get_pod_identifying_label_string() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator static method) _load_body_to_dict() (in module airflow.providers.cncf.kubernetes.hooks.kubernetes) _log_driver() (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor method) _render_nested_template_fields() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) _set_name() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) _task_status() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method) _try_numbers_match() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator static method)

A

airflow.providers.cncf.kubernetes module airflow.providers.cncf.kubernetes.backcompat module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters module airflow.providers.cncf.kubernetes.backcompat.pod module airflow.providers.cncf.kubernetes.backcompat.pod_runtime_info_env module airflow.providers.cncf.kubernetes.backcompat.volume module airflow.providers.cncf.kubernetes.backcompat.volume_mount module airflow.providers.cncf.kubernetes.hooks module

airflow.providers.cncf.kubernetes.hooks.kubernetes module airflow.providers.cncf.kubernetes.operators module airflow.providers.cncf.kubernetes.operators.kubernetes_pod module airflow.providers.cncf.kubernetes.operators.spark_kubernetes module airflow.providers.cncf.kubernetes.sensors module airflow.providers.cncf.kubernetes.sensors.spark_kubernetes module airflow.providers.cncf.kubernetes.utils module airflow.providers.cncf.kubernetes.utils.pod_launcher module api_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)

B

base_container_is_running() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method)

C

conn_name_attr (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) conn_type (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) convert_affinity() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) convert_configmap() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) convert_env_vars() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) convert_image_pull_secrets() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) convert_pod_runtime_info_env() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) convert_port() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters)

convert_resources() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) convert_toleration() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) convert_volume() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) convert_volume_mount() (in module airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters) create_custom_object() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) create_labels_for_pod() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator static method) create_new_pod_for_operator() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) create_pod_request_obj() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method)

D

default_conn_name (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute)

delete_pod() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method)

E

execute() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method)

F

FAILED (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodStatus attribute)

FAILURE_STATES (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute)

G

get_conn() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_connection_form_widgets() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook static method) get_custom_object() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)

get_namespace() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_pod_log_stream() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_pod_logs() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_ui_field_behaviour() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook static method)

H

handle_pod_overlap() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method)

hook_name (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute)

K

KubernetesHook (class in airflow.providers.cncf.kubernetes.hooks.kubernetes)

KubernetesPodOperator (class in airflow.providers.cncf.kubernetes.operators.kubernetes_pod)

M

module airflow.providers.cncf.kubernetes airflow.providers.cncf.kubernetes.backcompat airflow.providers.cncf.kubernetes.backcompat.backwards_compat_converters airflow.providers.cncf.kubernetes.backcompat.pod airflow.providers.cncf.kubernetes.backcompat.pod_runtime_info_env airflow.providers.cncf.kubernetes.backcompat.volume airflow.providers.cncf.kubernetes.backcompat.volume_mount airflow.providers.cncf.kubernetes.hooks airflow.providers.cncf.kubernetes.hooks.kubernetes airflow.providers.cncf.kubernetes.operators airflow.providers.cncf.kubernetes.operators.kubernetes_pod airflow.providers.cncf.kubernetes.operators.spark_kubernetes airflow.providers.cncf.kubernetes.sensors airflow.providers.cncf.kubernetes.sensors.spark_kubernetes airflow.providers.cncf.kubernetes.utils airflow.providers.cncf.kubernetes.utils.pod_launcher

monitor_launched_pod() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) monitor_pod() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method)

O

on_kill() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method)

P

parse_log_line() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method) patch_already_checked() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) PENDING (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodStatus attribute) pod_is_running() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method) pod_not_started() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method)

PodLauncher (class in airflow.providers.cncf.kubernetes.utils.pod_launcher) PodRuntimeInfoEnv (class in airflow.providers.cncf.kubernetes.backcompat.pod_runtime_info_env) PodStatus (class in airflow.providers.cncf.kubernetes.utils.pod_launcher) poke() (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor method) Port (class in airflow.providers.cncf.kubernetes.backcompat.pod) process_status() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method)

R

read_pod() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method) read_pod_events() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method) read_pod_logs() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method)

Resources (class in airflow.providers.cncf.kubernetes.backcompat.pod) run_pod_async() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method) RUNNING (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodStatus attribute)

S

should_retry_start_pod() (in module airflow.providers.cncf.kubernetes.utils.pod_launcher) SparkKubernetesOperator (class in airflow.providers.cncf.kubernetes.operators.spark_kubernetes) SparkKubernetesSensor (class in airflow.providers.cncf.kubernetes.sensors.spark_kubernetes)

start_pod() (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodLauncher method) SUCCEEDED (airflow.providers.cncf.kubernetes.utils.pod_launcher.PodStatus attribute) SUCCESS_STATES (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute)

T

template_ext (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) template_fields (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute)

to_k8s_client_obj() (airflow.providers.cncf.kubernetes.backcompat.pod.Port method) (airflow.providers.cncf.kubernetes.backcompat.pod.Resources method) (airflow.providers.cncf.kubernetes.backcompat.pod_runtime_info_env.PodRuntimeInfoEnv method) (airflow.providers.cncf.kubernetes.backcompat.volume.Volume method) (airflow.providers.cncf.kubernetes.backcompat.volume_mount.VolumeMount method)

U

ui_color (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute)

V

Volume (class in airflow.providers.cncf.kubernetes.backcompat.volume)

VolumeMount (class in airflow.providers.cncf.kubernetes.backcompat.volume_mount)

PreviousNext

Was this entry helpful?