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 150 ]; "
"do i=$(($i+1)); "
"echo $i; "
"sleep 1; "
"done; "
"mkdir -p /airflow/xcom/; "
'echo \'{"message": "good afternoon!"}\' > /airflow/xcom/return.json'
),
],
do_xcom_push=True,
logging_interval=5,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/cncf/kubernetes/example_dags/example_kubernetes_pod_operator.py