Bigquery Sensor Async¶
To checks for the existence of a table in Google Big Query
BigQueryTableExistenceSensorAsync
.
check_table_exists = BigQueryTableExistenceSensorAsync(
task_id="check_table_exists", project_id=PROJECT_ID, dataset_id=DATASET_NAME, table_id=TABLE_NAME
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/google/cloud/example_dags/example_bigquery_sensors.py