:py:mod:`astronomer.providers.apache.livy.triggers.livy`
========================================================

.. py:module:: astronomer.providers.apache.livy.triggers.livy

.. autoapi-nested-parse::

   This module contains the Apache Livy Trigger.



Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.apache.livy.triggers.livy.LivyTrigger




.. py:class:: LivyTrigger(batch_id, spark_params, livy_conn_id = 'livy_default', polling_interval = 0, extra_options = None, extra_headers = None, livy_hook_async = None)


   Bases: :py:obj:`airflow.triggers.base.BaseTrigger`

   This class is deprecated and will be removed in 2.0.0.
   Use :class: `~airflow.providers.apache.livy.triggers.livy.LivyTrigger` instead.

   .. py:method:: serialize()

      Serializes LivyTrigger arguments and classpath.


   .. py:method:: run()
      :async:

      Checks if the _polling_interval > 0, in that case it pools Livy for
      batch termination asynchrnonously.
      else returns the success response


   .. py:method:: poll_for_termination(batch_id)
      :async:

      Pool Livy for batch termination asynchrnonously.

      :param batch_id: id of the batch session to monitor.