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

此模块包含 Dataprep 作业传感器。

模块内容¶

类¶

DataprepJobGroupIsFinishedSensor

检查 Dataprep 任务的状态是否已完成。

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

基类: airflow.sensors.base.BaseSensorOperator

检查 Dataprep 任务的状态是否已完成。

参数: job_group_id (int | str) – 要检查的作业组 ID

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

poke(context)[源代码]¶

派生此类时重写。

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

模块内容¶

类¶

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