airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types¶

Attributes¶

`ADOPTED`
`CommandType`
`ALL_NAMESPACES`
`POD_EXECUTOR_DONE_KEY`
`POD_REVOKED_KEY`	Label to indicate pod revoked by executor.
`TASK_INSTANCE_ID_ANNOTATION`
`TASK_INSTANCE_ID_LABEL`

Classes¶

`FailureDetails`	Detailed information about pod/container failure.
`KubernetesResults`	Results from Kubernetes task execution.
`KubernetesWatch`	Watch event data from Kubernetes pods.
`KubernetesJob`	Job definition for Kubernetes execution.

Functions¶

task_instance_id_from_pod(pod)

Read immutable identity from an annotation or a pre-upgrade workload command.

Module Contents¶

airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.ADOPTED = 'adopted'[source]¶

class airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.FailureDetails[source]¶

Bases: TypedDict

Detailed information about pod/container failure.

pod_status: str | None[source]¶

pod_reason: str | None[source]¶

pod_message: str | None[source]¶

container_state: str | None[source]¶

container_reason: str | None[source]¶

container_message: str | None[source]¶

exit_code: int | None[source]¶

container_type: Literal['init', 'main'] | None[source]¶

container_name: str | None[source]¶

class airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.KubernetesResults[source]¶

Bases: NamedTuple

Results from Kubernetes task execution.

key: airflow.executors.workloads.types.TaskInstanceUuid | airflow.models.taskinstance.TaskInstanceKey[source]¶

state: airflow.utils.state.TaskInstanceState | str | None[source]¶

pod_name: str[source]¶

namespace: str[source]¶

resource_version: str[source]¶

failure_details: FailureDetails | None[source]¶

class airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.KubernetesWatch[source]¶

Bases: NamedTuple

Watch event data from Kubernetes pods.

pod_name: str[source]¶

namespace: str[source]¶

state: airflow.utils.state.TaskInstanceState | str | None[source]¶

annotations: dict[str, str][source]¶

resource_version: str[source]¶

failure_details: FailureDetails | None[source]¶

airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.CommandType = 'Sequence[str]'[source]¶

class airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.KubernetesJob[source]¶

Bases: NamedTuple

Job definition for Kubernetes execution.

key: airflow.executors.workloads.types.TaskInstanceUuid | airflow.models.taskinstance.TaskInstanceKey[source]¶

command: collections.abc.Sequence[str][source]¶

kube_executor_config: Any[source]¶

pod_template_file: str | None[source]¶

kube_image: str | None = None[source]¶

airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.ALL_NAMESPACES = 'ALL_NAMESPACES'[source]¶

airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.POD_EXECUTOR_DONE_KEY = 'airflow_executor_done'[source]¶

airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.POD_REVOKED_KEY = 'airflow_pod_revoked'[source]¶

Label to indicate pod revoked by executor.

When executor the executor revokes a task, the pod deletion is the result of the revocation. So we don’t want it to process that as an external deletion. So we want events on a revoked pod to be ignored.

airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.TASK_INSTANCE_ID_ANNOTATION = 'task_instance_id'[source]¶

airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.TASK_INSTANCE_ID_LABEL = 'ti_id'[source]¶

airflow.providers.cncf.kubernetes.executors.kubernetes_executor_types.task_instance_id_from_pod(pod)[source]¶

Read immutable identity from an annotation or a pre-upgrade workload command.

Pod templates can split the workload invocation between command and args. An invalid annotation is authoritative; falling back could attach a stale pod to another attempt.