airflow.contrib.sensors.gcp_transfer_sensor

Module Contents

class airflow.contrib.sensors.gcp_transfer_sensor.GCPTransferServiceWaitForJobStatusSensor(job_name, expected_statuses, project_id=None, gcp_conn_id='google_cloud_default', *args, **kwargs)

Bases:airflow.sensors.base_sensor_operator.BaseSensorOperator

Waits for at least one operation belonging to the job to have the expected status.

Parameters

• job_name (str) – The name of the transfer job

• expected_statuses (set[str] or string) – The expected state of the operation. See: https://cloud.google.com/storage-transfer/docs/reference/rest/v1/transferOperations#Status

• project_id (str) – (Optional) the ID of the project that owns the Transfer Job. If set to None or missing, the default project_id from the GCP connection is used.

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

template_fields = ['job_name']

poke(self, context)