Kubernetes Pod Operator Async

To asynchronously execute a task in a Kubernetes Pod KubernetesPodOperatorAsync.

create_k8s_pod = KubernetesPodOperatorAsync(
    task_id="create_k8s_pod",
    namespace=namespace,
    in_cluster=in_cluster,
    config_file=config_file,
    name="astro_k8s_test_pod",
    image="ubuntu",
    cmds=[
        "bash",
        "-cx",
        (
            "i=0; "
            "while [ $i -ne 30 ]; "
            "do i=$(($i+1)); "
            "echo $i; "
            "sleep 1; "
            "done; "
            "mkdir -p /airflow/xcom/; "
            'echo \'{"message": "good afternoon!"}\' > /airflow/xcom/return.json'
        ),
    ],
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/cncf/kubernetes/example_dags/example_kubernetes_pod_operator.py