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]¶

派生此类时重写。