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

此模块包含 Google Cloud Looker 传感器。

模块内容¶

类¶

LookerCheckPdtBuildSensor

检查先前提交的 PDT 物化作业的状态。

class airflow.providers.google.cloud.sensors.looker.LookerCheckPdtBuildSensor(materialization_id, looker_conn_id, cancel_on_kill=True, **kwargs)[源代码]¶

基类: airflow.sensors.base.BaseSensorOperator

检查先前提交的 PDT 物化作业的状态。

参数

materialization_id (str) – 必需。要轮询的物化作业 ID。（可使用模板）
looker_conn_id (str) – 必需。用于连接到 Looker 的连接 ID。
cancel_on_kill (bool) – 可选。标志，指示当调用 on_kill 时是否取消 hook 的作业。

template_fields = ['materialization_id'][源代码]¶

poke(context)[源代码]¶

在派生此类时覆盖。

on_kill()[源代码]¶

覆盖此方法以在任务实例被终止时清理子进程。

在操作符中使用的任何线程、子进程或多进程模块都需要清理，否则会留下僵尸进程。

airflow.providers.google.cloud.sensors.looker¶

模块内容¶

类¶

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