airflow.providers.google.cloud.sensors.looker
This module contains Google Cloud Looker sensors.
Module Contents
-
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]
-
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]
Override when deriving this class.
-
on_kill()[source]
Override this method to clean up 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.