Community
Meetups
Documentation
Use-cases
Announcements
Blog
Ecosystem
Community
Meetups
Documentation
Use-cases
Announcements
Blog
Ecosystem
Content
Version:
7.2.0
Basics
Home
Changelog
Security
Guides
Connection types
Operators
References
Python API
System tests
System Tests
Resources
Example DAGs
PyPI Repository
Installing from sources
Commits
Detailed list of commits
Version:
7.2.0
Basics
Home
Changelog
Security
Guides
Connection types
Operators
References
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
|
K
|
L
|
M
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
|
X
_
__str__() (airflow.providers.cncf.kubernetes.utils.delete_from.FailToDeleteError method)
__version__ (in module airflow.providers.cncf.kubernetes)
A
add_xcom_sidecar() (in module airflow.providers.cncf.kubernetes.utils.xcom_sidecar)
affinity (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
airflow.providers.cncf.kubernetes
module
airflow.providers.cncf.kubernetes.decorators
module
airflow.providers.cncf.kubernetes.decorators.kubernetes
module
airflow.providers.cncf.kubernetes.hooks
module
airflow.providers.cncf.kubernetes.hooks.kubernetes
module
airflow.providers.cncf.kubernetes.operators
module
airflow.providers.cncf.kubernetes.operators.kubernetes_pod
module
airflow.providers.cncf.kubernetes.operators.pod
module
airflow.providers.cncf.kubernetes.operators.resource
module
airflow.providers.cncf.kubernetes.operators.spark_kubernetes
module
airflow.providers.cncf.kubernetes.python_kubernetes_script
module
airflow.providers.cncf.kubernetes.sensors
module
airflow.providers.cncf.kubernetes.sensors.spark_kubernetes
module
airflow.providers.cncf.kubernetes.triggers
module
airflow.providers.cncf.kubernetes.triggers.kubernetes_pod
module
airflow.providers.cncf.kubernetes.triggers.pod
module
airflow.providers.cncf.kubernetes.utils
module
airflow.providers.cncf.kubernetes.utils.delete_from
module
airflow.providers.cncf.kubernetes.utils.pod_manager
module
airflow.providers.cncf.kubernetes.utils.xcom_sidecar
module
alphanum_lower (in module airflow.providers.cncf.kubernetes.operators.pod)
api_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
AsyncKubernetesHook (class in airflow.providers.cncf.kubernetes.hooks.kubernetes)
await_container_completion() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
await_pod_completion() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
await_pod_start() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
(airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
await_xcom_sidecar_container_start() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
B
BASE_CONTAINER_NAME (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)
build_pod_request_obj() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
C
cleanup() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
client() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
configmaps (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
conn_extras() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
conn_name_attr (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute)
conn_type (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute)
container_is_running() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
(in module airflow.providers.cncf.kubernetes.utils.pod_manager)
container_is_terminated() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
(in module airflow.providers.cncf.kubernetes.utils.pod_manager)
ContainerState (class in airflow.providers.cncf.kubernetes.triggers.pod)
core_v1_client (airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol property)
core_v1_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
create_custom_object() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
create_pod() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
custom_object_client() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
D
DAG_ID (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource)
(in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes)
default_conn_name (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute)
DEFAULT_DELETION_BODY (in module airflow.providers.cncf.kubernetes.utils.delete_from)
DEFAULT_NAMESPACE (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute)
define_container_state() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger method)
delete_custom_object() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
delete_from_dict() (in module airflow.providers.cncf.kubernetes.utils.delete_from)
delete_from_yaml() (in module airflow.providers.cncf.kubernetes.utils.delete_from)
DELETE_POD (airflow.providers.cncf.kubernetes.utils.pod_manager.OnFinishAction attribute)
delete_pod() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method)
(airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
DELETE_SUCCEEDED_POD (airflow.providers.cncf.kubernetes.utils.pod_manager.OnFinishAction attribute)
dry_run() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
E
ENV_ID (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource)
(in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes)
execute() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
(airflow.providers.cncf.kubernetes.operators.resource.KubernetesCreateResourceOperator method)
(airflow.providers.cncf.kubernetes.operators.resource.KubernetesDeleteResourceOperator method)
(airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method)
execute_async() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
execute_complete() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
execute_in_k8s_pod() (in module tests.system.providers.cncf.kubernetes.example_kubernetes_decorator)
execute_sync() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
extract_xcom() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
(airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
extract_xcom_json() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
extract_xcom_kill() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
F
FAILED (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute)
(airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute)
FailToDeleteError
FAILURE_STATES (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute)
fetch_container_logs() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
find_pod() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
follow_container_logs() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
G
get_conn() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method)
(airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
get_conn_extras() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method)
get_connection() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook class method)
get_connection_form_widgets() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook static method)
get_container_status() (in module airflow.providers.cncf.kubernetes.utils.pod_manager)
get_container_termination_message() (in module airflow.providers.cncf.kubernetes.utils.pod_manager)
get_custom_object() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
get_namespace() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
(airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol method)
get_namespaced_pod_list() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
get_or_create_pod() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
get_pod() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method)
(airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
(airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol method)
get_pod_log_stream() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
get_pod_logs() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook method)
get_ui_field_behaviour() (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook static method)
H
hook() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
hook_name (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook attribute)
I
init_container (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
init_container_volume_mounts (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
init_environments (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
invoke_defer_method() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
is_in_cluster (airflow.providers.cncf.kubernetes.hooks.kubernetes.KubernetesHook property)
(airflow.providers.cncf.kubernetes.utils.pod_manager.PodOperatorHookProtocol property)
K
k (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
KEEP_POD (airflow.providers.cncf.kubernetes.utils.pod_manager.OnFinishAction attribute)
KUBE_CONFIG_ENV_VAR (in module airflow.providers.cncf.kubernetes.operators.pod)
kubernetes_task() (in module airflow.providers.cncf.kubernetes.decorators.kubernetes)
KubernetesCreateResourceOperator (class in airflow.providers.cncf.kubernetes.operators.resource)
KubernetesDeleteResourceOperator (class in airflow.providers.cncf.kubernetes.operators.resource)
KubernetesHook (class in airflow.providers.cncf.kubernetes.hooks.kubernetes)
KubernetesPodOperator (class in airflow.providers.cncf.kubernetes.operators.pod)
KubernetesPodTrigger (class in airflow.providers.cncf.kubernetes.triggers.pod)
L
last_log_time (airflow.providers.cncf.kubernetes.utils.pod_manager.PodLoggingStatus attribute)
LOADING_KUBE_CONFIG_FILE_RESOURCE (in module airflow.providers.cncf.kubernetes.hooks.kubernetes)
M
module
airflow.providers.cncf.kubernetes
airflow.providers.cncf.kubernetes.decorators
airflow.providers.cncf.kubernetes.decorators.kubernetes
airflow.providers.cncf.kubernetes.hooks
airflow.providers.cncf.kubernetes.hooks.kubernetes
airflow.providers.cncf.kubernetes.operators
airflow.providers.cncf.kubernetes.operators.kubernetes_pod
airflow.providers.cncf.kubernetes.operators.pod
airflow.providers.cncf.kubernetes.operators.resource
airflow.providers.cncf.kubernetes.operators.spark_kubernetes
airflow.providers.cncf.kubernetes.python_kubernetes_script
airflow.providers.cncf.kubernetes.sensors
airflow.providers.cncf.kubernetes.sensors.spark_kubernetes
airflow.providers.cncf.kubernetes.triggers
airflow.providers.cncf.kubernetes.triggers.kubernetes_pod
airflow.providers.cncf.kubernetes.triggers.pod
airflow.providers.cncf.kubernetes.utils
airflow.providers.cncf.kubernetes.utils.delete_from
airflow.providers.cncf.kubernetes.utils.pod_manager
airflow.providers.cncf.kubernetes.utils.xcom_sidecar
tests.system.providers.cncf.kubernetes
tests.system.providers.cncf.kubernetes.example_kubernetes
tests.system.providers.cncf.kubernetes.example_kubernetes_async
tests.system.providers.cncf.kubernetes.example_kubernetes_decorator
tests.system.providers.cncf.kubernetes.example_kubernetes_resource
tests.system.providers.cncf.kubernetes.example_spark_kubernetes
O
on_kill() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
(airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator method)
OnFinishAction (class in airflow.providers.cncf.kubernetes.utils.pod_manager)
P
parse_log_line() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
patch_already_checked() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
PENDING (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute)
POD_CHECKED_KEY (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)
pod_manager() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
PodDefaults (class in airflow.providers.cncf.kubernetes.utils.xcom_sidecar)
PodLaunchFailedException
PodLoggingStatus (class in airflow.providers.cncf.kubernetes.utils.pod_manager)
PodManager (class in airflow.providers.cncf.kubernetes.utils.pod_manager)
PodOperatorHookProtocol (class in airflow.providers.cncf.kubernetes.utils.pod_manager)
PodPhase (class in airflow.providers.cncf.kubernetes.utils.pod_manager)
PodReattachFailure
poke() (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor method)
port (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
post_complete_action() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
POST_TERMINATION_TIMEOUT (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)
process_pod_deletion() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
pvc_conf (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource)
pvc_name (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource)
R
read_logs() (airflow.providers.cncf.kubernetes.hooks.kubernetes.AsyncKubernetesHook method)
read_pod() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
read_pod_events() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
read_pod_logs() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
remove_task_decorator() (in module airflow.providers.cncf.kubernetes.python_kubernetes_script)
run() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger method)
run_pod_async() (airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager method)
RUNNING (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute)
running (airflow.providers.cncf.kubernetes.utils.pod_manager.PodLoggingStatus attribute)
RUNNING (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute)
S
secret_all_keys (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
secret_env (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
secret_file (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
serialize() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger method)
should_retry_start_pod() (in module airflow.providers.cncf.kubernetes.utils.pod_manager)
should_wait() (airflow.providers.cncf.kubernetes.triggers.pod.KubernetesPodTrigger static method)
SIDECAR_CONTAINER (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)
SIDECAR_CONTAINER_NAME (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)
SparkKubernetesOperator (class in airflow.providers.cncf.kubernetes.operators.spark_kubernetes)
SparkKubernetesSensor (class in airflow.providers.cncf.kubernetes.sensors.spark_kubernetes)
SUCCEEDED (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute)
SUCCESS_STATES (airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute)
T
t1 (in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource)
(in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes)
template_ext (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute)
template_fields (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)
(airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute)
(airflow.providers.cncf.kubernetes.sensors.spark_kubernetes.SparkKubernetesSensor attribute)
template_fields_renderers (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator attribute)
terminal_states (airflow.providers.cncf.kubernetes.utils.pod_manager.PodPhase attribute)
TERMINATED (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute)
test_run (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_decorator)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_resource)
(in module tests.system.providers.cncf.kubernetes.example_spark_kubernetes)
tests.system.providers.cncf.kubernetes
module
tests.system.providers.cncf.kubernetes.example_kubernetes
module
tests.system.providers.cncf.kubernetes.example_kubernetes_async
module
tests.system.providers.cncf.kubernetes.example_kubernetes_decorator
module
tests.system.providers.cncf.kubernetes.example_kubernetes_resource
module
tests.system.providers.cncf.kubernetes.example_spark_kubernetes
module
tolerations (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
U
ui_color (airflow.providers.cncf.kubernetes.operators.spark_kubernetes.SparkKubernetesOperator attribute)
UNDEFINED (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute)
V
VOLUME (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)
volume (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
VOLUME_MOUNT (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)
volume_mount (in module tests.system.providers.cncf.kubernetes.example_kubernetes)
(in module tests.system.providers.cncf.kubernetes.example_kubernetes_async)
W
WAITING (airflow.providers.cncf.kubernetes.triggers.pod.ContainerState attribute)
write_logs() (airflow.providers.cncf.kubernetes.operators.pod.KubernetesPodOperator method)
write_python_script() (in module airflow.providers.cncf.kubernetes.python_kubernetes_script)
X
XCOM_CMD (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)
XCOM_MOUNT_PATH (airflow.providers.cncf.kubernetes.utils.xcom_sidecar.PodDefaults attribute)
Previous
Next
Was this entry helpful?
Suggest a change on this page