Community
Meetups
Documentation
Use Cases
Announcements
Blog
Ecosystem
Community
Meetups
Documentation
Use Cases
Announcements
Blog
Ecosystem
Content
Version:
9.0.1
Basics
Home
Changelog
Security
Executors
KubernetesExecutor details
LocalKubernetesExecutor details
Guides
Connection types
KubernetesPodOperator
SparkKubernetesOperator
KubernetesJobOperator
KubernetesDeleteJobOperator
KubernetesPatchJobOperator
References
Configuration
CLI
Python API
System tests
System Tests
Resources
Example DAGs
PyPI Repository
Installing from sources
Commits
Detailed list of commits
Version:
9.0.1
Basics
Home
Changelog
Security
Executors
KubernetesExecutor details
LocalKubernetesExecutor details
Guides
Connection types
KubernetesPodOperator
SparkKubernetesOperator
KubernetesJobOperator
KubernetesDeleteJobOperator
KubernetesPatchJobOperator
References
Configuration
CLI
Python API
System tests
System Tests
Resources
Example DAGs
PyPI Repository
Installing from sources
Commits
Detailed list of commits
Home
Index
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
X
_
__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.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.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.job
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.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
base_container_is_running() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method)
BASE_CONTAINER_NAME (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)
(airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute)
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_exception_is_kubernetes_api_unauthorized() (in module airflow.providers.cncf.kubernetes.utils.pod_manager)
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)
clear_not_launched_queued_tasks() (airflow.providers.cncf.kubernetes.executors.kubernetes_executor.KubernetesExecutor method)
client() (airflow.providers.cncf.kubernetes.operators.job.KubernetesDeleteJobOperator 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.cncf.kubernetes.example_kubernetes)
(in module tests.system.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_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_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.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_resource)
(in module tests.system.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.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_resource)
(in module tests.system.cncf.kubernetes.example_spark_kubernetes)
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.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)
(airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator 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_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)
generate_pod_yaml() (in module airflow.providers.cncf.kubernetes.cli.kubernetes_command)
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_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_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)
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 method)
(airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator method)
(airflow.providers.cncf.kubernetes.operators.job.KubernetesPatchJobOperator 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.job.KubernetesJobTrigger 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.cncf.kubernetes.example_kubernetes)
(in module tests.system.cncf.kubernetes.example_kubernetes_async)
init_container_volume_mounts (in module tests.system.cncf.kubernetes.example_kubernetes)
(in module tests.system.cncf.kubernetes.example_kubernetes_async)
init_environments (in module tests.system.cncf.kubernetes.example_kubernetes)
(in module tests.system.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_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_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_client() (airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator method)
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 (in module tests.system.cncf.kubernetes.example_kubernetes_job)
JOB_NAMESPACE (in module tests.system.cncf.kubernetes.example_kubernetes_job)
JOB_STATUS_CONDITION_TYPES (in module airflow.providers.cncf.kubernetes.hooks.kubernetes)
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)
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)
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)
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)
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)
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)
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_matching_pod() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
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.cli
airflow.providers.cncf.kubernetes.cli.kubernetes_command
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.job
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.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_resource
tests.system.cncf.kubernetes.example_spark_kubernetes
monitor_pod() (airflow.providers.cncf.kubernetes.pod_launcher_deprecated.PodLauncher method)
N
NORMAL (airflow.providers.cncf.kubernetes.operators.pod.PodEventType attribute)
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_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.pod_launcher_deprecated.PodStatus attribute)
(airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute)
pi_example_path (in module tests.system.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)
(airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger 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)
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)
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.cncf.kubernetes.example_kubernetes)
(in module tests.system.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_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)
(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.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_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.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.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.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)
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)
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)
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)
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
t1 (in module tests.system.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.KubernetesDeleteJobOperator attribute)
(airflow.providers.cncf.kubernetes.operators.job.KubernetesJobOperator 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)
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.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_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_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 (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)
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.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)
W
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.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)
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)
Previous
Next
Was this entry helpful?
Suggest a change on this page