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

本模块包含 Google Cloud Looker sensor。

类¶

LookerCheckPdtBuildSensor

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

模块内容¶

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

基类: 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'][source]¶

materialization_id[source]¶

looker_conn_id[source]¶

cancel_on_kill = True[source]¶

hook: airflow.providers.google.cloud.hooks.looker.LookerHook | None = None[source]¶

poke(context)[source]¶

派生此类时重写。

on_kill()[source]¶

当任务实例被终止时，重写此方法以清理子进程。

在 operator 中使用 threading、subprocess 或 multiprocessing 模块的任何地方都需要进行清理，否则会留下僵尸进程。