astronomer.providers.google.cloud.triggers.kubernetes_engine ============================================================ .. py:module:: astronomer.providers.google.cloud.triggers.kubernetes_engine Classes ------- .. autoapisummary:: astronomer.providers.google.cloud.triggers.kubernetes_engine.GKEStartPodTrigger Module Contents --------------- .. 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. This class is deprecated and will be removed in 2.0.0. Use :class: `~airflow.providers.google.cloud.triggers.kubernetes_engine.GKEStartPodTrigger` instead :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 :value: 'base' .. py:attribute:: POD_CHECKED_KEY :value: 'already_checked' .. py:attribute:: location .. py:attribute:: cluster_name .. py:attribute:: regional .. py:attribute:: use_internal_ip .. py:attribute:: project_id .. py:attribute:: gcp_conn_id .. py:attribute:: impersonation_chain .. py:attribute:: cluster_context .. py:attribute:: in_cluster .. py:attribute:: namespace .. py:attribute:: name .. py:attribute:: poll_interval .. py:attribute:: pending_phase_timeout .. py:attribute:: logging_interval .. py:method:: serialize() Serialize GKEStartPodTrigger object .. py:method:: run() :async: Wait for pod to reach terminal state