:py:mod:`astronomer.providers.apache.hive.triggers.hive_partition`
==================================================================

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


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

Classes
~~~~~~~

.. autoapisummary::

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




.. 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: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.