:py:mod:`astronomer.providers.apache.hive.triggers.named_hive_partition` ======================================================================== .. py:module:: astronomer.providers.apache.hive.triggers.named_hive_partition Module Contents --------------- Classes ~~~~~~~ .. autoapisummary:: astronomer.providers.apache.hive.triggers.named_hive_partition.NamedHivePartitionTrigger .. py:class:: NamedHivePartitionTrigger(partition_names, metastore_conn_id, polling_interval) 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 partition_names: List of fully qualified names of the partitions to wait for. :param metastore_conn_id: connection string to connect to hive. :param polling_interval: polling period in seconds to check for the partition. .. py:method:: serialize() Serializes NamedHivePartitionTrigger arguments and classpath. .. py:method:: run() :async: Run until found all given partition in Hive.