| :py:mod:`airflow.providers.google.cloud.sensors.looker` |
| ======================================================= |
| |
| .. py:module:: airflow.providers.google.cloud.sensors.looker |
| |
| .. autoapi-nested-parse:: |
| |
| This module contains Google Cloud Looker sensors. |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.google.cloud.sensors.looker.LookerCheckPdtBuildSensor |
| |
| |
| |
| |
| .. py:class:: LookerCheckPdtBuildSensor(materialization_id, looker_conn_id, cancel_on_kill = True, **kwargs) |
| |
| Bases: :py:obj:`airflow.sensors.base.BaseSensorOperator` |
| |
| Check for the state of a previously submitted PDT materialization job. |
| |
| :param materialization_id: Required. The materialization job ID to poll. (templated) |
| :param looker_conn_id: Required. The connection ID to use connecting to Looker. |
| :param cancel_on_kill: Optional. Flag which indicates whether cancel the hook's job or not, |
| when on_kill is called. |
| |
| .. py:attribute:: template_fields |
| :annotation: = ['materialization_id'] |
| |
| |
| |
| .. py:method:: poke(context) |
| |
| Function that the sensors defined while deriving this class should |
| override. |
| |
| |
| .. py:method:: on_kill() |
| |
| 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. |
| |
| |
| |
