:py:mod:`astronomer.providers.google.cloud.triggers.kubernetes_engine` ====================================================================== .. py:module:: astronomer.providers.google.cloud.triggers.kubernetes_engine Module Contents --------------- Classes ~~~~~~~ .. autoapisummary:: astronomer.providers.google.cloud.triggers.kubernetes_engine.GKEStartPodTrigger .. py:class:: 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) Bases: :py:obj:`astronomer.providers.cncf.kubernetes.triggers.wait_container.WaitContainerTrigger` Fetch GKE cluster config and wait for pod to start up. :param location: The name of the Google Kubernetes Engine zone or region in which the cluster resides :param cluster_name: The name of the Google Kubernetes Engine cluster the pod should be spawned in :param use_internal_ip: Use the internal IP address as the endpoint. :param project_id: The Google Developers Console project id :param gcp_conn_id: The google cloud connection id to use :param impersonation_chain: Optional service account to impersonate using short-term credentials :param regional: The location param is region name :param namespace: The cluster namespace :param name: The pod name :param cluster_context: Context that points to kubernetes cluster :param in_cluster: run kubernetes client with in_cluster configuration :param pending_phase_timeout: max time in seconds to wait for pod to leave pending phase .. py:attribute:: BASE_CONTAINER_NAME :annotation: = base .. py:attribute:: POD_CHECKED_KEY :annotation: = already_checked .. py:method:: serialize() Serialize GKEStartPodTrigger object .. py:method:: run() :async: Wait for pod to reach terminal state