astronomer.providers.google.cloud.triggers.kubernetes_engine

Classes

GKEStartPodTrigger

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

Module Contents

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.

This class is deprecated and will be removed in 2.0.0. Use :class: ~airflow.providers.google.cloud.triggers.kubernetes_engine.GKEStartPodTrigger instead

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 (str | None) – The Google Developers Console project id

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

  • impersonation_chain (str | Sequence[str] | None) – 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 (str | None) – Context that points to kubernetes cluster

  • in_cluster (bool | None) – 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'
location
cluster_name
regional
use_internal_ip
project_id
gcp_conn_id
impersonation_chain
cluster_context
in_cluster
namespace
name
poll_interval
pending_phase_timeout
logging_interval
serialize()[source]

Serialize GKEStartPodTrigger object

async run()[source]

Wait for pod to reach terminal state