:mod:`airflow.contrib.sensors.gcp_transfer_sensor`
==================================================

.. py:module:: airflow.contrib.sensors.gcp_transfer_sensor


Module Contents
---------------

.. py:class:: GCPTransferServiceWaitForJobStatusSensor(job_name, expected_statuses, project_id=None, gcp_conn_id='google_cloud_default', *args, **kwargs)

   Bases: :class:`airflow.sensors.base_sensor_operator.BaseSensorOperator`

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

   :param job_name: The name of the transfer job
   :type job_name: str
   :param expected_statuses: The expected state of the operation.
       See:
       https://cloud.google.com/storage-transfer/docs/reference/rest/v1/transferOperations#Status
   :type expected_statuses: set[str] or string
   :param project_id: (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.
   :type project_id: str
   :param gcp_conn_id: The connection ID used to connect to Google Cloud
       Platform.
   :type gcp_conn_id: str

   .. attribute:: template_fields
      :annotation: = ['job_name']

      
   .. method:: poke(self, context)