airflow.providers.cncf.kubernetes.utils.container¶

Helper functions for inspecting and interacting with containers in a Kubernetes Pod.

Functions¶

`get_container_status`(pod, container_name)	Retrieve container status.
`container_is_running`(pod, container_name)	Examine V1Pod `pod` to determine whether `container_name` is running.
`container_is_completed`(pod, container_name)	Examine V1Pod `pod` to determine whether `container_name` is completed.
`container_is_succeeded`(pod, container_name)	Examine V1Pod `pod` to determine whether `container_name` is completed and succeeded.
`container_is_wait`(pod, container_name)	Examine V1Pod `pod` to determine whether `container_name` is waiting.
`container_is_terminated`(pod, container_name)	Examine V1Pod `pod` to determine whether `container_name` is terminated.
`get_container_termination_message`(pod, container_name)

airflow.providers.cncf.kubernetes.utils.container.get_container_status(pod, container_name)[source]¶

Retrieve container status.

airflow.providers.cncf.kubernetes.utils.container.container_is_running(pod, container_name)[source]¶

Examine V1Pod pod to determine whether container_name is running.

If that container is present and running, returns True. Returns False otherwise.

airflow.providers.cncf.kubernetes.utils.container.container_is_completed(pod, container_name)[source]¶

Examine V1Pod pod to determine whether container_name is completed.

If that container is present and completed, returns True. Returns False otherwise.

airflow.providers.cncf.kubernetes.utils.container.container_is_succeeded(pod, container_name)[source]¶

Examine V1Pod pod to determine whether container_name is completed and succeeded.

If that container is present and completed and succeeded, returns True. Returns False otherwise.

airflow.providers.cncf.kubernetes.utils.container.container_is_wait(pod, container_name)[source]¶

Examine V1Pod pod to determine whether container_name is waiting.

If that container is present and waiting, returns True. Returns False otherwise.

airflow.providers.cncf.kubernetes.utils.container.container_is_terminated(pod, container_name)[source]¶

Examine V1Pod pod to determine whether container_name is terminated.

If that container is present and terminated, returns True. Returns False otherwise.

airflow.providers.cncf.kubernetes.utils.container.get_container_termination_message(pod, container_name)[source]¶