这是一个使用 KubernetesJobOperator 的示例 DAG。
模块内容
-
tests.system.cncf.kubernetes.example_kubernetes_job.ENV_ID[源代码]
-
tests.system.cncf.kubernetes.example_kubernetes_job.DAG_ID = 'example_kubernetes_job_operator'[源代码]
-
tests.system.cncf.kubernetes.example_kubernetes_job.JOB_NAME = 'test-pi'[源代码]
-
tests.system.cncf.kubernetes.example_kubernetes_job.JOB_NAMESPACE = 'default'[源代码]
-
tests.system.cncf.kubernetes.example_kubernetes_job.k8s_job[源代码]
-
tests.system.cncf.kubernetes.example_kubernetes_job.test_run[源代码]