airflow.providers.cncf.kubernetes.triggers.job¶
模块内容¶
类¶
KubernetesJobTrigger 在触发器工作器上运行，以检查 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)[源码]¶
基类：
airflow.triggers.base.BaseTriggerKubernetesJobTrigger 在触发器工作器上运行，以检查 Job 的状态。
- 参数
job_name (str) – 作业的名称。
job_namespace (str) – 作业的命名空间。
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 集群的上下文。
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。