:py:mod:`astronomer.providers.apache.hive.sensors.named_hive_partition`
=======================================================================

.. py:module:: astronomer.providers.apache.hive.sensors.named_hive_partition


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

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensorAsync




.. py:class:: NamedHivePartitionSensorAsync(*, partition_names, metastore_conn_id = 'metastore_default', poke_interval = 60 * 3, hook = None, **kwargs)

   Bases: :py:obj:`airflow.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensor`

   Waits asynchronously for a set of partitions to show up in Hive.

   :param partition_names: List of fully qualified names of the
       partitions to wait for. A fully qualified name is of the
       form ``schema.table/pk1=pv1/pk2=pv2``, for example,
       default.users/ds=2016-01-01.
   :param metastore_conn_id: Metastore thrift service connection id.

   .. py:method:: execute(self, context)

      Submit a job to Hive and defer


   .. py:method:: execute_complete(self, context, event = None)

      Callback for when the trigger fires - returns immediately.
      Relies on trigger to throw an exception, otherwise it assumes execution was
      successful.