• Home
• Index

Index

_

__eq__() (airflow.providers.cncf.kubernetes.secret.Secret method) __repr__() (airflow.providers.cncf.kubernetes.secret.Secret method)

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

A

active_deadline_seconds (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) add_sidecar() (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator static method) add_xcom_sidecar() (in module airflow.providers.cncf.kubernetes.utils.xcom_sidecar) adopt_launched_task() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) ADOPTED (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types) affinity (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) airflow.providers.cncf.kubernetes module airflow.providers.cncf.kubernetes.callbacks module airflow.providers.cncf.kubernetes.cli module airflow.providers.cncf.kubernetes.cli.kubernetes_command module airflow.providers.cncf.kubernetes.decorators module airflow.providers.cncf.kubernetes.decorators.kubernetes module airflow.providers.cncf.kubernetes.exceptions module airflow.providers.cncf.kubernetes.executors module airflow.providers.cncf.kubernetes.executors.kubernetes_executor module airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types module airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils module airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor module airflow.providers.cncf.kubernetes.hooks module airflow.providers.cncf.kubernetes.hooks.kubernetes module airflow.providers.cncf.kubernetes.k8s_model module airflow.providers.cncf.kubernetes.kube_client module airflow.providers.cncf.kubernetes.kube_config module airflow.providers.cncf.kubernetes.kubernetes_executor_templates module airflow.providers.cncf.kubernetes.kubernetes_helper_functions module airflow.providers.cncf.kubernetes.operators module airflow.providers.cncf.kubernetes.operators.custom_object_launcher module airflow.providers.cncf.kubernetes.operators.job module airflow.providers.cncf.kubernetes.operators.kueue 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.pod_generator module airflow.providers.cncf.kubernetes.pod_generator_deprecated module airflow.providers.cncf.kubernetes.pod_template_file_examples module airflow.providers.cncf.kubernetes.python_kubernetes_script module

airflow.providers.cncf.kubernetes.resource_convert module airflow.providers.cncf.kubernetes.resource_convert.configmap module airflow.providers.cncf.kubernetes.resource_convert.env_variable module airflow.providers.cncf.kubernetes.resource_convert.secret module airflow.providers.cncf.kubernetes.secret module airflow.providers.cncf.kubernetes.sensors module airflow.providers.cncf.kubernetes.sensors.spark_kubernetes module airflow.providers.cncf.kubernetes.template_rendering module airflow.providers.cncf.kubernetes.triggers module airflow.providers.cncf.kubernetes.triggers.job 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.k8s_resource_iterator module airflow.providers.cncf.kubernetes.utils.pod_manager module airflow.providers.cncf.kubernetes.utils.xcom_sidecar module airflow.providers.cncf.kubernetes.version_compat module airflow_home (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) AIRFLOW_V_2_10_PLUS (in module airflow.providers.cncf.kubernetes.version_compat) AIRFLOW_V_3_0_PLUS (in module airflow.providers.cncf.kubernetes.version_compat) AirflowKubernetesScheduler (class in airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils) ALL_NAMESPACES (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types) alphanum_lower (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) (in module airflow.providers.cncf.kubernetes.operators.pod) annotations (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) annotations_for_logging_task_metadata() (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) annotations_to_key() (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) api_client (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook property) api_exceptions (airflow.providers.cncf.kubernetes.utils.delete_from.FailToDeleteError attribute) api_group (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute) api_version (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute) append_to_pod() (in module airflow.providers.cncf.kubernetes.k8s_model) application_file (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) application_name (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute) apply_from_yaml_file() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) apps_v1_client (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook property) ARG_MIN_PENDING_MINUTES (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor) ARG_NAMESPACE (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor) arguments (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) ASYNC (airflow.providers.cncf.kubernetes.callbacks.ExecutionMode attribute) AsyncKubernetesHook (class in airflow.providers.cncf.kubernetes.hooks.kubernetes) attach_log (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute) attach_to_pod() (airflow.providers.cncf.kubernetes.k8s_model.K8SModel method) (airflow.providers.cncf.kubernetes.secret.Secret method) await_container_completion() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) await_init_containers_completion() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) await_pod_completion() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (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

backoff_limit (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) BASE_CONTAINER_NAME (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) base_container_name (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) BASE_CONTAINER_NAME (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) base_container_name (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute)

batch_v1_client (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook property) body (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator attribute) build_job_request_obj() (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator method) build_pod_request_obj() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)

C

callback_sink (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) callbacks (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) change_sensor_mode_to_reschedule (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) check_exception_is_kubernetes_api_unauthorized() (in module airflow.providers.cncf.kubernetes.utils.pod_manager) check_kueue_deployment_running() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) check_pod_start_failure() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher method) cleanup() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) cleanup_pods() (in module airflow.providers.cncf.kubernetes.cli.kubernetes_command) cleanup_stuck_queued_tasks() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) client (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator property) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator property) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator property) client_configuration (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) client_type (in module airflow.providers.cncf.kubernetes.callbacks) cluster_conf (in module tests.system.cncf.kubernetes.example_kubernetes_kueue) cluster_context (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) cmds (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) code_path (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) completion_mode (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) completions (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) config_dict (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) config_file (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) configmaps (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) conn_extras (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook property) conn_id (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) conn_name_attr (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute)

conn_type (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) construct_pod() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator class method) container (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator attribute) container_is_completed() (in module airflow.providers.cncf.kubernetes.utils.pod_manager) container_is_running() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) (in module airflow.providers.cncf.kubernetes.utils.pod_manager) container_is_succeeded() (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) container_is_wait() (in module airflow.providers.cncf.kubernetes.utils.pod_manager) container_logs (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) container_name (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute) container_resources (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) container_security_context (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) ContainerState (class in airflow.providers.cncf.kubernetes.triggers.pod) convert_config_file_to_dict() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) convert_configmap() (in module airflow.providers.cncf.kubernetes.resource_convert.configmap) convert_configmap_to_volume() (in module airflow.providers.cncf.kubernetes.resource_convert.configmap) convert_env_vars() (in module airflow.providers.cncf.kubernetes.resource_convert.env_variable) convert_image_pull_secrets() (in module airflow.providers.cncf.kubernetes.resource_convert.secret) convert_resources() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkResources method) convert_secret() (in module airflow.providers.cncf.kubernetes.resource_convert.secret) core_configuration (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) core_section (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) core_v1_client (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook property) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol property) create_custom_from_yaml_object() (airflow.providers.cncf.kubernetes.operators.resource.KubernetesCreateResourceOperator method) create_custom_object() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) create_job() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator method) create_job_name() (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) create_labels_for_pod() (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator static method) create_pod() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) create_unique_id() (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) custom_obj_api (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator property) custom_object_client (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook property) CustomObjectLauncher (class in airflow.providers.cncf.kubernetes.operators.custom_object_launcher) CustomObjectStatus (class in airflow.providers.cncf.kubernetes.operators.custom_object_launcher)

D

DAG_ID (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) (in module tests.system.cncf.kubernetes.example_kubernetes_job) (in module tests.system.cncf.kubernetes.example_kubernetes_kueue) (in module tests.system.cncf.kubernetes.example_kubernetes_resource) (in module tests.system.cncf.kubernetes.example_spark_kubernetes) dags_folder (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) datetime_to_label_safe_datestring() (in module airflow.providers.cncf.kubernetes.pod_generator) debug_dump() (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) default (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkResources attribute) 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) deferrable (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) define_container_state() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger method) delete_custom_from_yaml_object() (airflow.providers.cncf.kubernetes.operators.resource.KubernetesDeleteResourceOperator 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_on_status (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) delete_on_termination (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) delete_option_kwargs (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute)

DELETE_POD (airflow.providers.cncf.kubernetes.utils.pod_manager.OnFinishAction attribute) delete_pod() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler method) (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) delete_spark_job() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher method) DELETE_SUCCEEDED_POD (airflow.providers.cncf.kubernetes.utils.pod_manager.OnFinishAction attribute) delete_worker_pods (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) delete_worker_pods_on_failure (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) deploy_target (airflow.providers.cncf.kubernetes.secret.Secret attribute) deploy_type (airflow.providers.cncf.kubernetes.secret.Secret attribute) deserialize_job_template_file() (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator static method) deserialize_model_dict() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) deserialize_model_file() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) disable_tcp_keepalive (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) disable_verify_ssl (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) dns_config (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) dnspolicy (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) do_xcom_push (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) driver (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkResources attribute) driver_resources (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkResources property) dry_run() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method)

E

end() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) env_from (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) ENV_ID (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) (in module tests.system.cncf.kubernetes.example_kubernetes_job) (in module tests.system.cncf.kubernetes.example_kubernetes_kueue) (in module tests.system.cncf.kubernetes.example_kubernetes_resource) (in module tests.system.cncf.kubernetes.example_spark_kubernetes) env_vars (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) execute() (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator method) (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator method) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator method) (airflow.providers.cncf.kubernetes.operators.kueue.KubernetesInstallKueueOperator method) (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.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) execute_complete() (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator method) execute_deferrable() (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator method) execute_in_k8s_pod() (in module tests.system.cncf.kubernetes.example_kubernetes_decorator) execute_sync() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) ExecutionMode (class in airflow.providers.cncf.kubernetes.callbacks) executor (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkResources attribute) executor_namespace (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) executor_resources (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkResources property) extend_object_field() (in module airflow.providers.cncf.kubernetes.pod_generator) extract_xcom (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator attribute) (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator attribute) 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.operators.custom_object_launcher.CustomObjectStatus attribute) (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) find_pod() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)

find_spark_job() (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) flavor_conf (in module tests.system.cncf.kubernetes.example_kubernetes_kueue) from_obj() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator static method) full_job_spec (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) full_pod_spec (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)

G

gen_pod() (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator method) generate_pod_yaml() (in module airflow.providers.cncf.kubernetes.cli.kubernetes_command) get_base_airflow_version_tuple() (in module airflow.providers.cncf.kubernetes.version_compat) get_base_pod_from_template() (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils) get_body() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher method) get_cli_commands() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor static method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor static method) 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 class 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_deployment_status() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_event_buffer() (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) get_job() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_job_status() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) get_kube_client() (in module airflow.providers.cncf.kubernetes.kube_client) get_logs (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute)

get_logs_task_metadata() (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) 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_or_create_spark_crd() (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator 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_combined_search_str_to_pod_map() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor 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_rendered_k8s_spec() (in module airflow.providers.cncf.kubernetes.template_rendering) get_task_log() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) get_ui_field_behaviour() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook class method) get_xcom_sidecar_container_image() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol method) get_xcom_sidecar_container_resources() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol method) get_yaml_content_from_file() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook static method)

H

has_kubernetes (in module airflow.providers.cncf.kubernetes.kube_client) has_task() (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) heartbeat() (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) hook (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator property) (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator property) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator property) (airflow.providers.cncf.kubernetes.operators.kueue.KubernetesInstallKueueOperator property) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator property) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator property) (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor property) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger property) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger property)

hook_name (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) host_aliases (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) hostname (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) hostnetwork (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)

I

image (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) image_pull_policy (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) image_pull_secrets (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) in_cluster (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) init_container (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) init_container_logs (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) init_container_volume_mounts (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) init_containers (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)

init_environments (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) install_kueue (in module tests.system.cncf.kubernetes.example_kubernetes_kueue) 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) is_istio_enabled() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) is_job_complete() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) is_job_failed() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook static method) is_job_successful() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook static method) is_local (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) is_log_group_marker() (in module airflow.providers.cncf.kubernetes.utils.pod_manager) is_production (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) is_single_threaded (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) ISTIO_CONTAINER_NAME (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) items (airflow.providers.cncf.kubernetes.secret.Secret attribute)

J

job (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) job_client (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator property) JOB_FINAL_STATUS_CONDITION_TYPES (in module airflow.providers.cncf.kubernetes.hooks.kubernetes) job_id (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor property) job_name (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) JOB_NAME (in module tests.system.cncf.kubernetes.example_kubernetes_job)

job_namespace (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) JOB_NAMESPACE (in module tests.system.cncf.kubernetes.example_kubernetes_job) job_poll_interval (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) job_request_obj (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) JOB_STATUS_CONDITION_TYPES (in module airflow.providers.cncf.kubernetes.hooks.kubernetes) job_template_file (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute)

K

k (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) k8s_job (in module tests.system.cncf.kubernetes.example_kubernetes_job) k8s_resource_iterator() (in module airflow.providers.cncf.kubernetes.utils.k8s_resource_iterator) K8SModel (class in airflow.providers.cncf.kubernetes.k8s_model) KEEP_POD (airflow.providers.cncf.kubernetes.utils.pod_manager.OnFinishAction attribute) key (airflow.providers.cncf.kubernetes.secret.Secret attribute) KILL_ISTIO_PROXY_SUCCESS_MSG (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) kill_istio_sidecar() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) kind (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher attribute) kube_client (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler attribute) kube_client_request_args (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) kube_config (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler attribute) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher attribute) KUBE_CONFIG_ENV_VAR (in module airflow.providers.cncf.kubernetes.operators.pod) kube_namespace (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) kube_scheduler (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) kube_watchers (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler attribute) KubeConfig (class in airflow.providers.cncf.kubernetes.kube_config) KUBERNETES_COMMANDS (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor) kubernetes_conn_id (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.kueue.KubernetesInstallKueueOperator attribute) (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) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute)

kubernetes_executor (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) kubernetes_queue (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) KUBERNETES_QUEUE (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) kubernetes_section (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) kubernetes_task() (in module airflow.providers.cncf.kubernetes.decorators.kubernetes) KubernetesCreateResourceOperator (class in airflow.providers.cncf.kubernetes.operators.resource) KubernetesDeleteJobOperator (class in airflow.providers.cncf.kubernetes.operators.job) KubernetesDeleteResourceOperator (class in airflow.providers.cncf.kubernetes.operators.resource) KubernetesExecutor (class in airflow.providers.cncf.kubernetes.executors.kubernetes_executor) KubernetesHook (class in airflow.providers.cncf.kubernetes.hooks.kubernetes) KubernetesInstallKueueOperator (class in airflow.providers.cncf.kubernetes.operators.kueue) KubernetesJobOperator (class in airflow.providers.cncf.kubernetes.operators.job) KubernetesJobTrigger (class in airflow.providers.cncf.kubernetes.triggers.job) KubernetesJobType (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types) KubernetesJobWatcher (class in airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils) KubernetesPatchJobOperator (class in airflow.providers.cncf.kubernetes.operators.job) KubernetesPodOperator (class in airflow.providers.cncf.kubernetes.operators.pod) KubernetesPodOperatorCallback (class in airflow.providers.cncf.kubernetes.callbacks) KubernetesPodTrigger (class in airflow.providers.cncf.kubernetes.triggers.pod) KubernetesSpec (class in airflow.providers.cncf.kubernetes.operators.custom_object_launcher) KubernetesStartKueueJobOperator (class in airflow.providers.cncf.kubernetes.operators.kueue) kueue_version (airflow.providers.cncf.kubernetes.operators.kueue.KubernetesInstallKueueOperator attribute)

L

label_safe_datestring_to_datetime() (in module airflow.providers.cncf.kubernetes.pod_generator) labels (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) last_handled (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) last_log_time (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodLoggingStatus attribute) list_jobs_all_namespaces() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) list_jobs_from_namespace() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) LOADING_KUBE_CONFIG_FILE_RESOURCE (in module airflow.providers.cncf.kubernetes.hooks.kubernetes) local_conf (in module tests.system.cncf.kubernetes.example_kubernetes_kueue) local_executor (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) LocalKubernetesExecutor (class in airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor)

log (in module airflow.providers.cncf.kubernetes.kube_client) (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) (in module airflow.providers.cncf.kubernetes.operators.job) (in module airflow.providers.cncf.kubernetes.pod_generator) log_events_on_failure (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) log_matching_pod() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) log_pod_spec_on_failure (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) logging_interval (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) logging_section (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute)

M

make_safe_label_value() (in module airflow.providers.cncf.kubernetes.pod_generator) (in module airflow.providers.cncf.kubernetes.pod_generator_deprecated) make_unique_pod_id() (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator static method) manage_template_specs() (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) manual_selector (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) MAX_LABEL_LEN (in module airflow.providers.cncf.kubernetes.pod_generator) (in module airflow.providers.cncf.kubernetes.pod_generator_deprecated) MAX_POD_ID_LEN (in module airflow.providers.cncf.kubernetes.pod_generator_deprecated) merge_objects() (in module airflow.providers.cncf.kubernetes.pod_generator) metadata (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator attribute) module airflow.providers.cncf.kubernetes airflow.providers.cncf.kubernetes.callbacks airflow.providers.cncf.kubernetes.cli airflow.providers.cncf.kubernetes.cli.kubernetes_command airflow.providers.cncf.kubernetes.decorators airflow.providers.cncf.kubernetes.decorators.kubernetes airflow.providers.cncf.kubernetes.exceptions airflow.providers.cncf.kubernetes.executors airflow.providers.cncf.kubernetes.executors.kubernetes_executor airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor airflow.providers.cncf.kubernetes.hooks airflow.providers.cncf.kubernetes.hooks.kubernetes airflow.providers.cncf.kubernetes.k8s_model airflow.providers.cncf.kubernetes.kube_client airflow.providers.cncf.kubernetes.kube_config airflow.providers.cncf.kubernetes.kubernetes_executor_templates airflow.providers.cncf.kubernetes.kubernetes_helper_functions airflow.providers.cncf.kubernetes.operators airflow.providers.cncf.kubernetes.operators.custom_object_launcher airflow.providers.cncf.kubernetes.operators.job airflow.providers.cncf.kubernetes.operators.kueue airflow.providers.cncf.kubernetes.operators.pod airflow.providers.cncf.kubernetes.operators.resource airflow.providers.cncf.kubernetes.operators.spark_kubernetes airflow.providers.cncf.kubernetes.pod_generator airflow.providers.cncf.kubernetes.pod_generator_deprecated airflow.providers.cncf.kubernetes.pod_template_file_examples airflow.providers.cncf.kubernetes.python_kubernetes_script airflow.providers.cncf.kubernetes.resource_convert airflow.providers.cncf.kubernetes.resource_convert.configmap airflow.providers.cncf.kubernetes.resource_convert.env_variable airflow.providers.cncf.kubernetes.resource_convert.secret airflow.providers.cncf.kubernetes.secret airflow.providers.cncf.kubernetes.sensors airflow.providers.cncf.kubernetes.sensors.spark_kubernetes airflow.providers.cncf.kubernetes.template_rendering airflow.providers.cncf.kubernetes.triggers airflow.providers.cncf.kubernetes.triggers.job airflow.providers.cncf.kubernetes.triggers.pod airflow.providers.cncf.kubernetes.utils airflow.providers.cncf.kubernetes.utils.delete_from airflow.providers.cncf.kubernetes.utils.k8s_resource_iterator airflow.providers.cncf.kubernetes.utils.pod_manager airflow.providers.cncf.kubernetes.utils.xcom_sidecar airflow.providers.cncf.kubernetes.version_compat tests.system.cncf.kubernetes tests.system.cncf.kubernetes.example_kubernetes tests.system.cncf.kubernetes.example_kubernetes_async tests.system.cncf.kubernetes.example_kubernetes_decorator tests.system.cncf.kubernetes.example_kubernetes_job tests.system.cncf.kubernetes.example_kubernetes_kueue tests.system.cncf.kubernetes.example_kubernetes_resource tests.system.cncf.kubernetes.example_spark_kubernetes

multi_namespace_mode (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute)

N

name (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) namespace (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler attribute) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher attribute) (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator attribute) (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)

node_selector (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) NORMAL (airflow.providers.cncf.kubernetes.operators.pod.PodEventType attribute)

O

on_finish_action (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) on_kill() (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator method) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) on_operator_resuming() (airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback static method) on_pod_cleanup() (airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback static method)

on_pod_completion() (airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback static method) on_pod_creation() (airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback static method) on_pod_manifest_created() (airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback static method) on_pod_starting() (airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback static method) on_pod_teardown() (airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback static method) on_sync_client_creation() (airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback static method) OnFinishAction (class in airflow.providers.cncf.kubernetes.utils.pod_manager)

P

parallelism (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) parse_log_line() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) patch_already_checked() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) patch_namespaced_job() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) patch_pod_executor_done() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler method) PENDING (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute) pi_example_path (in module tests.system.cncf.kubernetes.example_spark_kubernetes) plural (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher attribute) pod (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator attribute) POD_CHECKED_KEY (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) POD_EXECUTOR_DONE_KEY (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types) pod_manager (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher property) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator property) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator property) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger property) pod_name (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) POD_NAME_MAX_LENGTH (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) pod_namespace (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) pod_request_obj (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) pod_runtime_info_envs (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) pod_spec (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher attribute) pod_template_dict (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) pod_template_file (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) PodCredentialsExpiredFailure PodDefaults (class in airflow.providers.cncf.kubernetes.pod_generator_deprecated) (class in airflow.providers.cncf.kubernetes.utils.xcom_sidecar)

PodEventType (class in airflow.providers.cncf.kubernetes.operators.pod) PodGenerator (class in airflow.providers.cncf.kubernetes.pod_generator) (class in airflow.providers.cncf.kubernetes.pod_generator_deprecated) PodLaunchFailedException PodLaunchTimeoutException PodLoggingStatus (class in airflow.providers.cncf.kubernetes.utils.pod_manager) PodManager (class in airflow.providers.cncf.kubernetes.utils.pod_manager) PodMutationHookException PodNotFoundException PodOperatorHookProtocol (class in airflow.providers.cncf.kubernetes.utils.pod_manager) PodPhase (class in airflow.providers.cncf.kubernetes.utils.pod_manager) PodReattachFailure PodReconciliationError poke() (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor method) poll_interval (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger attribute) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) port (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) ports (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) post_complete_action() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) POST_TERMINATION_TIMEOUT (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) priority_class_name (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) process_duplicate_label_pods() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) process_error() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher method) process_pod_deletion() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) process_status() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher method) process_watcher_task() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler method) progress_callback() (airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback static method) pvc_conf (in module tests.system.cncf.kubernetes.example_kubernetes_resource) pvc_name (in module tests.system.cncf.kubernetes.example_kubernetes_resource)

Q

queue_command() (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) queue_name (airflow.providers.cncf.kubernetes.operators.kueue.KubernetesStartKueueJobOperator attribute)

QUEUE_NAME (in module tests.system.cncf.kubernetes.example_kubernetes_kueue) queue_task_instance() (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) queued_tasks (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor property)

R

random_name_suffix (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) 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) reattach_on_restart (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) reconcile_containers() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) reconcile_job_specs() (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator static method) reconcile_jobs() (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator static method) reconcile_metadata() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) reconcile_pods() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) reconcile_specs() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) remote_pod (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) remove_task_decorator() (in module airflow.providers.cncf.kubernetes.python_kubernetes_script) render_k8s_pod_yaml() (in module airflow.providers.cncf.kubernetes.template_rendering) resource_version (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher attribute) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.ResourceVersion attribute)

resources (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkResources property) ResourceVersion (class in airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils) result_queue (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler attribute) revoke_task() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) run() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher method) (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger method) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger method) run_next() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler method) run_pod_async() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) running (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor property) RUNNING (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectStatus attribute) (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) RUNNING_POD_LOG_LINES (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute)

S

scheduler_job_id (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler attribute) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher attribute) schedulername (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) secret (airflow.providers.cncf.kubernetes.secret.Secret attribute) Secret (class in airflow.providers.cncf.kubernetes.secret) secret_all_keys (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) secret_env (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) secret_file (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) secrets (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) security_context (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) selector (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) send_callback() (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) serialize() (airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger method) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger method) serialize_pod() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) serve_logs (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) service_account_name (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) set_attribute() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.KubernetesSpec method) should_retry_creation() (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) should_retry_start_pod() (in module airflow.providers.cncf.kubernetes.utils.pod_manager) should_retry_start_spark_job() (in module airflow.providers.cncf.kubernetes.operators.custom_object_launcher) should_wait() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger static method) SIDECAR_CONTAINER (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodDefaults attribute) (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute) SIDECAR_CONTAINER_NAME (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodDefaults attribute) (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute) skip_on_exit_code (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)

slots_available (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor property) slots_occupied (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor property) spark_job_not_running() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher method) spark_obj_spec (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher attribute) SparkJobSpec (class in airflow.providers.cncf.kubernetes.operators.custom_object_launcher) SparkKubernetesOperator (class in airflow.providers.cncf.kubernetes.operators.spark_kubernetes) SparkKubernetesSensor (class in airflow.providers.cncf.kubernetes.sensors.spark_kubernetes) SparkResources (class in airflow.providers.cncf.kubernetes.operators.custom_object_launcher) spec (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator attribute) start() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) start_spark_job() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher method) startup_check_interval (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) startup_check_interval_seconds (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) startup_timeout (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) startup_timeout_seconds (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) subdomain (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) SUBMITTED (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectStatus attribute) SUCCEEDED (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectStatus attribute) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute) success_run_history_limit (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) SUCCESS_STATES (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute) supports_ad_hoc_ti_run (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) supports_pickling (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) supports_sentry (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) suspend (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) SYNC (airflow.providers.cncf.kubernetes.callbacks.ExecutionMode attribute) sync() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler method)

T

t1 (in module tests.system.cncf.kubernetes.example_kubernetes_resource) task_publish_max_retries (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) task_publish_retries (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) task_queue (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor attribute) template_body (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher attribute) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator property) template_ext (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) template_fields (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator attribute) (airflow.providers.cncf.kubernetes.operators.kueue.KubernetesInstallKueueOperator attribute) (airflow.providers.cncf.kubernetes.operators.kueue.KubernetesStartKueueJobOperator attribute) (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) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) template_spec (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute) terminal_states (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute) terminate() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) TERMINATED (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute) termination_grace_period (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) termination_message_policy (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) test_run (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) (in module tests.system.cncf.kubernetes.example_kubernetes_decorator) (in module tests.system.cncf.kubernetes.example_kubernetes_job) (in module tests.system.cncf.kubernetes.example_kubernetes_kueue) (in module tests.system.cncf.kubernetes.example_kubernetes_resource) (in module tests.system.cncf.kubernetes.example_spark_kubernetes)

tests.system.cncf.kubernetes module tests.system.cncf.kubernetes.example_kubernetes module tests.system.cncf.kubernetes.example_kubernetes_async module tests.system.cncf.kubernetes.example_kubernetes_decorator module tests.system.cncf.kubernetes.example_kubernetes_job module tests.system.cncf.kubernetes.example_kubernetes_kueue module tests.system.cncf.kubernetes.example_kubernetes_resource module tests.system.cncf.kubernetes.example_spark_kubernetes module to_env_from_secret() (airflow.providers.cncf.kubernetes.secret.Secret method) to_env_secret() (airflow.providers.cncf.kubernetes.secret.Secret method) to_volume_secret() (airflow.providers.cncf.kubernetes.secret.Secret method) tolerations (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) trigger_reentry() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) trigger_start_time (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger attribute) try_adopt_task_instances() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) ttl_seconds_after_finished (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute)

U

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

UNDEFINED (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute) update_resources() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkJobSpec method)

V

validate() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkJobSpec method) VOLUME (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodDefaults attribute) (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute) volume (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async)

VOLUME_MOUNT (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodDefaults attribute) (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute) volume_mount (in module tests.system.cncf.kubernetes.example_kubernetes) (in module tests.system.cncf.kubernetes.example_kubernetes_async) volume_mounts (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) volumes (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)

W

wait_for_completion (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator attribute) wait_until_container_complete() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) wait_until_container_started() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) wait_until_job_complete (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator attribute) wait_until_job_complete() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) WAITING (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute)

WARNING (airflow.providers.cncf.kubernetes.operators.pod.PodEventType attribute) watcher_queue (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler attribute) (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher attribute) worker_container_repository (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) worker_container_tag (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) worker_pod_pending_fatal_container_state_reasons (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) worker_pods_creation_batch_size (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) write_python_script() (in module airflow.providers.cncf.kubernetes.python_kubernetes_script)

X

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

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

PreviousNext

Was this entry helpful?