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.BaseSensorOperator

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

Parameters
template_fields = ['job_name'][source]
poke(self, context)[source]

Was this entry helpful?