airflow.providers.google.cloud.triggers.cloud_storage_transfer_service

Module Contents

Classes

CloudStorageTransferServiceCreateJobsTrigger

StorageTransferJobTrigger run on the trigger worker to perform Cloud Storage Transfer job.
class airflow.providers.google.cloud.triggers.cloud_storage_transfer_service.CloudStorageTransferServiceCreateJobsTrigger(job_names, project_id=None, poll_interval=10, gcp_conn_id='google_cloud_default')[source]

Bases: airflow.triggers.base.BaseTrigger

StorageTransferJobTrigger run on the trigger worker to perform Cloud Storage Transfer job.

Parameters

  • job_names (list[str]) – List of transfer jobs names.

  • project_id (str | None) – GCP project id.

  • poll_interval (int) – Interval in seconds between polls.

  • gcp_conn_id (str) – The connection ID used to connect to Google Cloud.

serialize()[source]

Serialize StorageTransferJobsTrigger arguments and classpath.

async run()[source]

Get current data storage transfer jobs and yields a TriggerEvent.

get_async_hook()[source]

Was this entry helpful?