`airflow.providers.cncf.kubernetes.callbacks`¶

模組內容¶

`ExecutionMode`	執行模式的列舉類別。
`KubernetesPodOperatorCallback`	KubernetesPodOperator 回呼方法。

class airflow.providers.cncf.kubernetes.callbacks.ExecutionMode[原始碼]¶

基底類別： str、 enum.Enum

執行模式的列舉類別。

class airflow.providers.cncf.kubernetes.callbacks.KubernetesPodOperatorCallback[原始碼]¶

KubernetesPodOperator 回呼方法。

目前，回呼方法在非同步模式下不會被呼叫，此支援將在未來新增。

static on_sync_client_creation(*, client, **kwargs)[原始碼]¶

在建立同步用戶端後調用此回呼。

參數: client (kubernetes.client.CoreV1Api) – 已建立的 kubernetes.client.CoreV1Api 用戶端。

static on_pod_creation(*, pod, client, mode, **kwargs)[原始碼]¶

在建立 Pod 後調用此回呼。

參數

static on_pod_starting(*, pod, client, mode, **kwargs)[原始碼]¶

在 Pod 啟動時調用此回呼。

參數

static on_pod_completion(*, pod, client, mode, **kwargs)[原始碼]¶

在 Pod 完成時調用此回呼。

參數

static on_pod_cleanup(*, pod, client, mode, **kwargs)[原始碼]¶

在清理/刪除 Pod 後調用此回呼。

參數

static on_operator_resuming(*, pod, event, client, mode, **kwargs)[原始碼]¶

在從延遲狀態恢復 KubernetesPodOperator 時調用此回呼。

參數

static progress_callback(*, line, client, mode, **kwargs)[原始碼]¶

調用此回呼以處理 Pod 容器日誌。

參數