Hive Partition Sensor Async¶
To asynchronously wait for a partition to show up in Hive table
HivePartitionSensorAsync
.
hive_sensor = HivePartitionSensorAsync(
task_id="hive_partition_check",
table=HIVE_TABLE,
partition=HIVE_PARTITION,
poke_interval=5,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/apache/hive/example_dags/example_hive.py