• Home
• Index

Index

_

__str__() (airflow.providers.cncf.kubernetes.utils.delete_from.FailToDeleteError method)

__version__ (in module airflow.providers.cncf.kubernetes)

A

add_xcom_sidecar() (in module airflow.providers.cncf.kubernetes.utils.xcom_sidecar) affinity (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) airflow.providers.cncf.kubernetes module airflow.providers.cncf.kubernetes.decorators module airflow.providers.cncf.kubernetes.decorators.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.pod module airflow.providers.cncf.kubernetes.operators.resource module airflow.providers.cncf.kubernetes.operators.spark_kubernetes module airflow.providers.cncf.kubernetes.python_kubernetes_script module

airflow.providers.cncf.kubernetes.sensors module airflow.providers.cncf.kubernetes.sensors.spark_kubernetes module airflow.providers.cncf.kubernetes.triggers module airflow.providers.cncf.kubernetes.triggers.kubernetes_pod module airflow.providers.cncf.kubernetes.triggers.pod module airflow.providers.cncf.kubernetes.utils module airflow.providers.cncf.kubernetes.utils.delete_from module airflow.providers.cncf.kubernetes.utils.pod_manager module airflow.providers.cncf.kubernetes.utils.xcom_sidecar module alphanum_lower (in module airflow.providers.cncf.kubernetes.operators.pod) api_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) AsyncKubernetesHook (class in airflow.providers.cncf.kubernetes.hooks.kubernetes) 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.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) await_xcom_sidecar_container_start() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)

B

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

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

C

cleanup() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) client() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) configmaps (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) conn_extras() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook 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)

container_is_terminated() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) (in module airflow.providers.cncf.kubernetes.utils.pod_manager) ContainerState (class in airflow.providers.cncf.kubernetes.triggers.pod) core_v1_client (airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol property) 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) custom_object_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)

D

DAG_ID (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource) (in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes) default_conn_name (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) DEFAULT_DELETION_BODY (in module airflow.providers.cncf.kubernetes.utils.delete_from) DEFAULT_NAMESPACE (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) define_container_state() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger method)

delete_custom_object() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) delete_from_dict() (in module airflow.providers.cncf.kubernetes.utils.delete_from) delete_from_yaml() (in module airflow.providers.cncf.kubernetes.utils.delete_from) DELETE_POD (airflow.providers.cncf.kubernetes.utils.pod_manager.OnFinishAction attribute) delete_pod() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) DELETE_SUCCEEDED_POD (airflow.providers.cncf.kubernetes.utils.pod_manager.OnFinishAction attribute) dry_run() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)

E

ENV_ID (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource) (in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes) execute() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.operators.resource.KubernetesCreateResourceOperator method) (airflow.providers.cncf.kubernetes.operators.resource.KubernetesDeleteResourceOperator method) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method)

execute_async() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) execute_complete() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) execute_in_k8s_pod() (in module tests.system.providers.cncf.kubernetes.example_kubernetes_decorator) execute_sync() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) extract_xcom() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) extract_xcom_json() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) extract_xcom_kill() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)

F

FAILED (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute) FailToDeleteError

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.pod.KubernetesPodOperator method) follow_container_logs() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)

G

get_conn() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_conn_extras() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) get_connection() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook class method) get_connection_form_widgets() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook static method) get_container_status() (in module airflow.providers.cncf.kubernetes.utils.pod_manager) 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) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol method)

get_namespaced_pod_list() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_or_create_pod() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) get_pod() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol 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() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)

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

I

init_container (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) init_container_volume_mounts (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)

init_environments (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) invoke_defer_method() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) is_in_cluster (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook property) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol property)

K

k (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) KEEP_POD (airflow.providers.cncf.kubernetes.utils.pod_manager.OnFinishAction attribute) KUBE_CONFIG_ENV_VAR (in module airflow.providers.cncf.kubernetes.operators.pod) kubernetes_task() (in module airflow.providers.cncf.kubernetes.decorators.kubernetes)

KubernetesCreateResourceOperator (class in airflow.providers.cncf.kubernetes.operators.resource) KubernetesDeleteResourceOperator (class in airflow.providers.cncf.kubernetes.operators.resource) KubernetesHook (class in airflow.providers.cncf.kubernetes.hooks.kubernetes) KubernetesPodOperator (class in airflow.providers.cncf.kubernetes.operators.pod) KubernetesPodTrigger (class in airflow.providers.cncf.kubernetes.triggers.pod)

L

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

LOADING_KUBE_CONFIG_FILE_RESOURCE (in module airflow.providers.cncf.kubernetes.hooks.kubernetes)

M

module airflow.providers.cncf.kubernetes airflow.providers.cncf.kubernetes.decorators airflow.providers.cncf.kubernetes.decorators.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.pod airflow.providers.cncf.kubernetes.operators.resource airflow.providers.cncf.kubernetes.operators.spark_kubernetes airflow.providers.cncf.kubernetes.python_kubernetes_script airflow.providers.cncf.kubernetes.sensors airflow.providers.cncf.kubernetes.sensors.spark_kubernetes airflow.providers.cncf.kubernetes.triggers airflow.providers.cncf.kubernetes.triggers.kubernetes_pod airflow.providers.cncf.kubernetes.triggers.pod airflow.providers.cncf.kubernetes.utils airflow.providers.cncf.kubernetes.utils.delete_from airflow.providers.cncf.kubernetes.utils.pod_manager airflow.providers.cncf.kubernetes.utils.xcom_sidecar tests.system.providers.cncf.kubernetes tests.system.providers.cncf.kubernetes.example_kubernetes tests.system.providers.cncf.kubernetes.example_kubernetes_async tests.system.providers.cncf.kubernetes.example_kubernetes_decorator tests.system.providers.cncf.kubernetes.example_kubernetes_resource tests.system.providers.cncf.kubernetes.example_spark_kubernetes

O

on_kill() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method)

OnFinishAction (class in airflow.providers.cncf.kubernetes.utils.pod_manager)

P

parse_log_line() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) patch_already_checked() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) PENDING (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute) POD_CHECKED_KEY (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) pod_manager() (airflow.providers.cncf.kubernetes.operators.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) PodOperatorHookProtocol (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) port (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) post_complete_action() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) POST_TERMINATION_TIMEOUT (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) process_pod_deletion() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) pvc_conf (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource) pvc_name (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource)

R

read_logs() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) 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) remove_task_decorator() (in module airflow.providers.cncf.kubernetes.python_kubernetes_script)

run() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger method) run_pod_async() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) RUNNING (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute) running (airflow.providers.cncf.kubernetes.utils.pod_manager.PodLoggingStatus attribute) RUNNING (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute)

S

secret_all_keys (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) secret_env (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) secret_file (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) serialize() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger method)

should_retry_start_pod() (in module airflow.providers.cncf.kubernetes.utils.pod_manager) should_wait() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger static method) 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

t1 (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource) (in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes) template_ext (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) template_fields (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute) template_fields_renderers (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) terminal_states (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute) TERMINATED (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute) test_run (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_decorator) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource) (in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes)

tests.system.providers.cncf.kubernetes module tests.system.providers.cncf.kubernetes.example_kubernetes module tests.system.providers.cncf.kubernetes.example_kubernetes_async module tests.system.providers.cncf.kubernetes.example_kubernetes_decorator module tests.system.providers.cncf.kubernetes.example_kubernetes_resource module tests.system.providers.cncf.kubernetes.example_spark_kubernetes module tolerations (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)

U

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

UNDEFINED (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute)

V

VOLUME (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute) volume (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)

VOLUME_MOUNT (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute) volume_mount (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)

W

WAITING (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute)

write_logs() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) write_python_script() (in module airflow.providers.cncf.kubernetes.python_kubernetes_script)

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?