• Home
• Index

Index

_

__call__() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.Singleton method) __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

add_sidecar() (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator static method) add_xcom_sidecar() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) (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 (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.callbacks module airflow.providers.cncf.kubernetes.decorators module airflow.providers.cncf.kubernetes.decorators.kubernetes 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.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.pod_generator module airflow.providers.cncf.kubernetes.pod_generator_deprecated module

airflow.providers.cncf.kubernetes.pod_launcher_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.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.k8s_resource_iterator module airflow.providers.cncf.kubernetes.utils.pod_manager module airflow.providers.cncf.kubernetes.utils.xcom_sidecar module 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_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 method) append_to_pod() (in module airflow.providers.cncf.kubernetes.k8s_model) apps_v1_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) ARG_MIN_PENDING_MINUTES (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor) ARG_NAMESPACE (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor) ASYNC (airflow.providers.cncf.kubernetes.callbacks.ExecutionMode attribute) AsyncKubernetesHook (class in airflow.providers.cncf.kubernetes.hooks.kubernetes) 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_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_is_running() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method) BASE_CONTAINER_NAME (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) base_version (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor)

batch_v1_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) 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) change_sensor_mode_to_reschedule (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) check_pod_start_failure() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher method) cleanup() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) cleanup_stuck_queued_tasks() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) clear_not_launched_queued_tasks() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) client() (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) client_type (in module airflow.providers.cncf.kubernetes.callbacks) 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) construct_pod() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator class method) 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)

ContainerState (class in airflow.providers.cncf.kubernetes.triggers.pod) 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_section (airflow.providers.cncf.kubernetes.kube_config.KubeConfig attribute) 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_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_pod_id() (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) create_unique_id() (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) custom_obj_api() (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) custom_object_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method) 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.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_job) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource) (in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes) 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_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_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_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.pod_launcher_deprecated.PodLauncher 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) 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) 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_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_job) (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.job.KubernetesJobOperator 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.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) ExecutionMode (class in airflow.providers.cncf.kubernetes.callbacks) 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.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.pod_launcher_deprecated.PodStatus 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) follow_container_logs() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) from_legacy_obj() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) from_obj() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator static method) (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator static method)

G

gen_pod() (airflow.providers.cncf.kubernetes.pod_generator.PodGenerator method) (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator method) 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_names() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager 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_kube_client() (in module airflow.providers.cncf.kubernetes.kube_client)

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_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)

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.KubernetesJobOperator method) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor method) (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger 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) is_istio_enabled() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) is_local (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) 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)

J

job_id (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor property)

K

k (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) k8s_job (in module tests.system.providers.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) KILL_ISTIO_PROXY_SUCCESS_MSG (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute) kill_istio_sidecar() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) KUBE_CONFIG_ENV_VAR (in module airflow.providers.cncf.kubernetes.operators.pod) KubeConfig (class in airflow.providers.cncf.kubernetes.kube_config) KUBERNETES_COMMANDS (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor) 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) 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) KubernetesJobOperator (class in airflow.providers.cncf.kubernetes.operators.job) KubernetesJobType (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types) KubernetesJobWatcher (class in airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils) 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)

L

label_safe_datestring_to_datetime() (in module airflow.providers.cncf.kubernetes.pod_generator) 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) 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) 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.PodGenerator static method) (airflow.providers.cncf.kubernetes.pod_generator_deprecated.PodGenerator static method) manage_template_specs() (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) 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) module airflow.providers.cncf.kubernetes airflow.providers.cncf.kubernetes.callbacks airflow.providers.cncf.kubernetes.decorators airflow.providers.cncf.kubernetes.decorators.kubernetes 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.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.pod_generator airflow.providers.cncf.kubernetes.pod_generator_deprecated airflow.providers.cncf.kubernetes.pod_launcher_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.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.k8s_resource_iterator 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_job tests.system.providers.cncf.kubernetes.example_kubernetes_resource tests.system.providers.cncf.kubernetes.example_spark_kubernetes

monitor_pod() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method)

O

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_starting() (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

parse_log_line() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method) (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_pod_executor_done() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.AirflowKubernetesScheduler method) PENDING (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodStatus attribute) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute) pi_example_path (in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes) 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_is_running() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method) pod_manager() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher method) (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method) POD_NAME_MAX_LENGTH (in module airflow.providers.cncf.kubernetes.kubernetes_helper_functions) pod_not_started() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method) PodDefaults (class in airflow.providers.cncf.kubernetes.pod_generator_deprecated) (class in airflow.providers.cncf.kubernetes.utils.xcom_sidecar) PodGenerator (class in airflow.providers.cncf.kubernetes.pod_generator) (class in airflow.providers.cncf.kubernetes.pod_generator_deprecated) PodLauncher (class in airflow.providers.cncf.kubernetes.pod_launcher_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 PodStatus (class in airflow.providers.cncf.kubernetes.pod_launcher_deprecated) 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_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) (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher 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.providers.cncf.kubernetes.example_kubernetes_resource) pvc_name (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource)

Q

queue_command() (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method)

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

read_logs() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method) read_pod() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) read_pod_events() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) read_pod_logs() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method) 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) 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.ResourceVersion attribute) resources (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.SparkResources property) ResourceVersion (class in airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils) run() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher 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.pod_launcher_deprecated.PodLauncher 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.pod_launcher_deprecated.PodStatus 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

Secret (class in airflow.providers.cncf.kubernetes.secret) 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) send_callback() (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) serialize() (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) set_attribute() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.KubernetesSpec method) 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) Singleton (class in airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils) slots_available (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor property)

spark_job_not_running() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher method) 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) start() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method) start_pod() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method) start_spark_job() (airflow.providers.cncf.kubernetes.operators.custom_object_launcher.CustomObjectLauncher method) 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.pod_launcher_deprecated.PodStatus attribute) (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase 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) 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

T (in module airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils) t1 (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource) template_body (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.KubernetesJobOperator 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) 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) 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_job) (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_job module tests.system.providers.cncf.kubernetes.example_kubernetes_resource module tests.system.providers.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 (in module tests.system.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.cncf.kubernetes.example_kubernetes_async) trigger_reentry() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method) try_adopt_task_instances() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method) (airflow.providers.cncf.kubernetes.executors.local_kubernetes_executor.LocalKubernetesExecutor method)

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.providers.cncf.kubernetes.example_kubernetes) (in module tests.system.providers.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.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.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?