cncf.kubernetes.operators.kubernetes_pod

Module Contents

Classes

KubernetesPodOperatorAsync

Async (deferring) version of KubernetesPodOperator

exception cncf.kubernetes.operators.kubernetes_pod.PodNotFoundException

Bases: airflow.exceptions.AirflowException

Expected pod does not exist in kube-api.

class cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperatorAsync(*, poll_interval=5, **kwargs)

Bases: airflow.providers.cncf.kubernetes.operators.kubernetes_pod.KubernetesPodOperator

Async (deferring) version of KubernetesPodOperator

Parameters

poll_interval (int) – interval in seconds to sleep between checking pod status

static raise_for_trigger_status(event)

Raise exception if pod is not in expected state.

execute(self, context)

execute_complete(self, context, event)

Callback for when the trigger fires - returns immediately. Relies on trigger to throw an exception, otherwise it assumes execution was successful.