airflow.providers.google.cloud.sensors.looker

This module contains Google Cloud Looker sensors.

Module Contents

Classes

LookerCheckPdtBuildSensor

Check for the state of a previously submitted PDT materialization job.
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]

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.

Was this entry helpful?