airflow.providers.cncf.kubernetes.triggers.job¶
模組內容¶
類別¶
KubernetesJobTrigger 在觸發器 worker 上執行以檢查 Job 的狀態。 |
- class airflow.providers.cncf.kubernetes.triggers.job.KubernetesJobTrigger(job_name, job_namespace, pod_name, pod_namespace, base_container_name, kubernetes_conn_id=None, poll_interval=10.0, cluster_context=None, config_file=None, in_cluster=None, get_logs=True, do_xcom_push=False)[source]¶
繼承自：
airflow.triggers.base.BaseTriggerKubernetesJobTrigger 在觸發器 worker 上執行以檢查 Job 的狀態。
- 參數
job_name (str) – Job 的名稱。
job_namespace (str) – Job 的命名空間。
pod_name (str) – Pod 的名稱。
pod_namespace (str) – Pod 的命名空間。
base_container_name (str) – Pod 中基礎容器的名稱。
kubernetes_conn_id (str | None) – Kubernetes 叢集的 kubernetes 連線 ID。
cluster_context (str | None) – 指向 Kubernetes 叢集的 Context。
config_file (str | None) – kubeconfig 檔案的路徑。
poll_interval (float) – 檢查狀態的輪詢週期（秒）。
in_cluster (bool | None) – 使用 in-cluster 設定執行 Kubernetes 用戶端。
get_logs (bool) – 取得基礎容器的 stdout 作為任務日誌。
do_xcom_push (bool) – 若為 True，當容器完成時，容器中 /airflow/xcom/return.json 檔案的內容也會被推送到 XCom。