| :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) |
| |
| |
| |
| |
