• Home
• Index

Index

A

add_xcom_sidecar() (in module airflow.providers.cncf.kubernetes.utils.xcom_sidecar) airflow.providers.cncf.kubernetes 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_manager module airflow.providers.cncf.kubernetes.utils.xcom_sidecar module api_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) await_container_completion() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) await_pod_completion() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) await_pod_start() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)

B

BASE_CONTAINER_NAME (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator attribute)

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

C

cleanup() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) client() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) conn_name_attr (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) conn_type (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute)

container_is_running() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) (in module airflow.providers.cncf.kubernetes.utils.pod_manager) core_v1_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) create_custom_object() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) create_pod() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)

D

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

delete_pod() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) dry_run() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method)

E

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

extract_xcom() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)

F

FAILED (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute) FAILURE_STATES (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute)

fetch_container_logs() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) find_pod() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) follow_container_logs() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)

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_container_termination_message() (in module airflow.providers.cncf.kubernetes.utils.pod_manager) get_custom_object() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)

get_namespace() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_or_create_pod() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator 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

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)

L

last_log_time (airflow.providers.cncf.kubernetes.utils.pod_manager.PodLoggingStatus attribute)

M

module airflow.providers.cncf.kubernetes 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_manager airflow.providers.cncf.kubernetes.utils.xcom_sidecar

O

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

P

parse_log_line() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) patch_already_checked() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) PENDING (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute) POD_CHECKED_KEY (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator attribute) pod_manager() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method) PodDefaults (class in airflow.providers.cncf.kubernetes.utils.xcom_sidecar)

PodLaunchFailedException PodLoggingStatus (class in airflow.providers.cncf.kubernetes.utils.pod_manager) PodManager (class in airflow.providers.cncf.kubernetes.utils.pod_manager) PodPhase (class in airflow.providers.cncf.kubernetes.utils.pod_manager) PodReattachFailure poke() (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor method) process_pod_deletion() (airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator method)

R

read_pod() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) read_pod_events() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) read_pod_logs() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)

run_pod_async() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) running (airflow.providers.cncf.kubernetes.utils.pod_manager.PodLoggingStatus attribute) RUNNING (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute)

S

should_retry_start_pod() (in module airflow.providers.cncf.kubernetes.utils.pod_manager) SIDECAR_CONTAINER (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute) SIDECAR_CONTAINER_NAME (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)

SparkKubernetesOperator (class in airflow.providers.cncf.kubernetes.operators.spark_kubernetes) SparkKubernetesSensor (class in airflow.providers.cncf.kubernetes.sensors.spark_kubernetes) SUCCEEDED (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase 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)

terminal_states (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute)

U

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

V

VOLUME (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)

VOLUME_MOUNT (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)

X

XCOM_CMD (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)

XCOM_MOUNT_PATH (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)

PreviousNext

Was this entry helpful?