astronomer.providers.google.cloud.triggers.kubernetes_engine

Module Contents

Classes

GKEStartPodTrigger

Fetch GKE cluster config and wait for pod to start up.
class astronomer.providers.google.cloud.triggers.kubernetes_engine.GKEStartPodTrigger(*, location, namespace, name, cluster_name='default', use_internal_ip=False, project_id=None, gcp_conn_id='google_cloud_default', impersonation_chain=None, regional=False, cluster_context=None, in_cluster=None, poll_interval=5.0, pending_phase_timeout=120.0, logging_interval=None)[source]

Bases: astronomer.providers.cncf.kubernetes.triggers.wait_container.WaitContainerTrigger

Fetch GKE cluster config and wait for pod to start up.

Parameters:

  • location (str) – The name of the Google Kubernetes Engine zone or region in which the cluster resides

  • cluster_name (str) – The name of the Google Kubernetes Engine cluster the pod should be spawned in

  • use_internal_ip (bool) – Use the internal IP address as the endpoint.

  • project_id (Optional[str]) – The Google Developers Console project id

  • gcp_conn_id (str) – The google cloud connection id to use

  • impersonation_chain (Optional[Union[str, Sequence[str]]]) – Optional service account to impersonate using short-term credentials

  • regional (bool) – The location param is region name

  • namespace (str) – The cluster namespace

  • name (str) – The pod name

  • cluster_context (Optional[str]) – Context that points to kubernetes cluster

  • in_cluster (Optional[bool]) – run kubernetes client with in_cluster configuration

  • pending_phase_timeout (float) – max time in seconds to wait for pod to leave pending phase

BASE_CONTAINER_NAME = base
POD_CHECKED_KEY = already_checked
serialize()[source]

Serialize GKEStartPodTrigger object

async run()[source]

Wait for pod to reach terminal state