airflow.providers.google.cloud.sensors.dataprep

This module contains a Dataprep Job sensor.

Module Contents

Classes

DataprepJobGroupIsFinishedSensor

Check the status of the Dataprep task to be finished.
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 :Sequence[str] = ['job_group_id'][source]
poke(context)[source]

Function defined by the sensors while deriving this class should override.

Was this entry helpful?