airflow_kubernetes_pod_operator_echo_command_example.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    k = KubernetesPodOperator(
15        namespace="default",
16        image="perl:5.34.0",
17        cmds=["perl", "-e", 'print "hello world\n"'],
18        labels={"foo": "bar"},
19        name="airflow-test-pod",
20        task_id="task-one",
21        in_cluster=False, # Set to True if running inside a K8s cluster
22        cluster_context="docker-desktop", # Replace with your kubeconfig context
23        is_delete_operator_pod=True,
24        get_logs=True,
25    )
26    # [END howto_operator_kubernetes]