airflow.providers.google.cloud.triggers.kubernetes_engine

Module Contents

Classes

GKEOperationTrigger

Trigger which checks status of the operation.
class airflow.providers.google.cloud.triggers.kubernetes_engine.GKEOperationTrigger(operation_name, project_id, location, gcp_conn_id='google_cloud_default', delegate_to=None, impersonation_chain=None, poll_interval=10)[source]

Bases: airflow.triggers.base.BaseTrigger

Trigger which checks status of the operation.

serialize()[source]

Serializes GKEOperationTrigger arguments and classpath.

async run()[source]

Gets operation status and yields corresponding event.

Was this entry helpful?