airflow_kubernetes_pod_operator_hello_world_dag.py

1from datetime import datetime
2from airflow import DAG
3from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator
4from kubernetes.client import models as k8s
5
6with DAG(
7    dag_id='example_kubernetes_operator',
8    schedule=None,
9    start_date=datetime(2021, 1, 1),
10    tags=['example'],
11) as dag:
12
13    # [START howto_operator_kubernetes]
14    k8s_task = KubernetesPodOperator(
15        task_id="run_pod",
16        name="say-hello",
17        namespace="default",
18        image="bash",
19        cmds=["bash", "-cx"],
20        arguments=["echo Hello World!"],
21        labels={"foo": "bar"},
22        get_logs=True,
23    )
24    # [END howto_operator_kubernetes]