NamedHivePartitionTrigger

Astronomer ProvidersCertified

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

Access Instructions

Install the Astronomer Providers provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

partition_namesList of fully qualified names of the partitions to wait for.
metastore_conn_idconnection string to connect to hive.
polling_intervalpolling period in seconds to check for the partition.

Documentation

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

Was this page helpful?