GKE Start Pod Operator Async¶
To executes a task in a Kubernetes pod in the specified Google Kubernetes Engine cluster
GKEStartPodOperatorAsync
.
start_pod = GKEStartPodOperatorAsync(
task_id="start_pod",
project_id=PROJECT_ID,
location=LOCATION,
cluster_name=GKE_CLUSTER_NAME,
name="astro_k8s_gke_test_pod",
namespace=GKE_NAMESPACE,
image="ubuntu",
in_cluster=False,
gcp_conn_id=GCP_CONN_ID,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/google/cloud/example_dags/example_kubernetes_engine.py