Named Hive Partition Sensor Async¶
To asynchronously wait for a set of partitions to show up in Hive table
NamedHivePartitionSensorAsync
.
wait_for_partition = NamedHivePartitionSensorAsync(
task_id="wait_for_partition",
partition_names=[f"{HIVE_SCHEMA}.{HIVE_TABLE}/{HIVE_PARTITION}"],
poke_interval=5,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/apache/hive/example_dags/example_hive.py