airflow.providers.google.cloud.sensors.dataprep¶

This module contains a Dataprep Job sensor.

Classes¶

DataprepJobGroupIsFinishedSensor

Check the status of the Dataprep task to be finished.

Module Contents¶

class airflow.providers.google.cloud.sensors.dataprep.DataprepJobGroupIsFinishedSensor(*, job_group_id, dataprep_conn_id='dataprep_default', **kwargs)[source]¶

Bases: airflow.sensors.base.BaseSensorOperator

Check the status of the Dataprep task to be finished.

Parameters:: job_group_id (int | str) – ID of the job group to check

template_fields: collections.abc.Sequence[str] = ('job_group_id',)[source]¶

job_group_id[source]¶

dataprep_conn_id = 'dataprep_default'[source]¶

poke(context)[source]¶

Override when deriving this class.