airflow_kubernetes_pod_operator_dag_echo_command_example.py

1import datetime
2
3from airflow import DAG
4from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator
5from kubernetes.client import models as k8s
6
7with DAG(
8    dag_id="example_kubernetes_operator",
9    schedule=None,
10    start_date=datetime.datetime(2021, 1, 1),
11    catchup=False,
12    tags=["example"],
13) as dag:
14    # [START howto_operator_kubernetes_pod]
15    k8s_task = KubernetesPodOperator(
16        task_id="dry_run_demo",
17        name="hello-dry-run",
18        image="bash",
19        cmds=["bash", "-cx"],
20        arguments=["echo", "10"],
21        labels={"foo": "bar"},
22        # Specify the namespace to run within
23        namespace="default",
24        # Authentication to a cluster is usually handled by the environment 
25        # (e.g., ServiceAccount in K8s or local kubeconfig)
26        get_logs=True,
27    )
28    # [END howto_operator_kubernetes_pod]