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)[source]¶ Bases:
airflow.sensors.base_sensor_operator.BaseSensorOperatorWaits 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.