astronomer.providers.apache.hive.triggers.hive_partition
========================================================

.. py:module:: astronomer.providers.apache.hive.triggers.hive_partition


Classes
-------

.. autoapisummary::

   astronomer.providers.apache.hive.triggers.hive_partition.HivePartitionTrigger


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

.. py:class:: HivePartitionTrigger(table, partition, polling_interval, metastore_conn_id, schema)

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


   A trigger that fires and it looks for a partition in the given table
   in the database or wait for the partition.

   :param table: the table where the partition is present.
   :param partition: The partition clause to wait for.
   :param schema: database which needs to be connected in hive.
   :param metastore_conn_id: connection string to connect to hive.
   :param polling_period_seconds: polling period in seconds to check for the partition.


   .. py:attribute:: table


   .. py:attribute:: partition


   .. py:attribute:: polling_interval


   .. py:attribute:: metastore_conn_id
      :type:  str


   .. py:attribute:: schema


   .. py:method:: serialize()

      Serializes HivePartitionTrigger arguments and classpath.



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


      Simple loop until the relevant table partition is present in the table or wait for it.