Airflow Summit 2026 is coming August 31 - September 2 in Austin, TX. Register now to secure your spot!

tests.system.cncf.kubernetes.example_kubernetes_pod_exec¶

Example Dag for executing a command in an existing Kubernetes Pod.

Attributes¶

`ENV_ID`
`DAG_ID`
`NAMESPACE`
`POD_NAME`
`CONTAINER_NAME`
`EXPECTED_OUTPUT`
`pod_conf`
`create_pod`
`test_run`

Functions¶

`wait_for_running_pod`()
`verify_output`(output)

Module Contents¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.ENV_ID[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.DAG_ID = 'example_kubernetes_pod_exec_operator'[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.NAMESPACE = 'default'[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.POD_NAME[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.CONTAINER_NAME = 'worker'[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.EXPECTED_OUTPUT = 'command executed in existing pod'[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.pod_conf[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.wait_for_running_pod()[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.verify_output(output)[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.create_pod[source]¶

tests.system.cncf.kubernetes.example_kubernetes_pod_exec.test_run[source]¶

Was this entry helpful?