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

此模組包含一個 Dataprep Job 感測器。

類¶

DataprepJobGroupIsFinishedSensor

檢查 Dataprep 任務的狀態是否已完成。

模組內容¶

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

基類: airflow.sensors.base.BaseSensorOperator

檢查 Dataprep 任務的狀態是否已完成。

引數:: job_group_id (int | str) – 要檢查的作業組 ID

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

job_group_id[source]¶

dataprep_conn_id = 'dataprep_default'[source]¶

poke(context)[source]¶

派生此類時重寫。