This module contains Google Cloud Looker sensors.
Module Contents
Classes
-
class airflow.providers.google.cloud.sensors.looker.LookerCheckPdtBuildSensor(materialization_id, looker_conn_id, cancel_on_kill=True, **kwargs)[source]
Bases: airflow.sensors.base.BaseSensorOperator
Check for the state of a previously submitted PDT materialization job.
- Parameters
materialization_id (str) – Required. The materialization job ID to poll. (templated)
looker_conn_id (str) – Required. The connection ID to use connecting to Looker.
cancel_on_kill (bool) – Optional. Flag which indicates whether cancel the hook’s job or not,
when on_kill is called.
-
template_fields = ['materialization_id'][source]
-
poke(context)[source]
Function that the sensors defined while deriving this class should
override.
-
on_kill()[source]
Override this method to cleanup subprocesses when a task instance
gets killed. Any use of the threading, subprocess or multiprocessing
module within an operator needs to be cleaned up or it will leave
ghost processes behind.
