BigQueryValueCheckTrigger
GoogleBigQueryValueCheckTrigger run on the trigger worker, inherits from BigQueryInsertJobTrigger class
Access Instructions
Install the Google provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
conn_idReference to google cloud connection id
sqlthe sql to be executed
pass_valuepass value
job_idThe ID of the job
project_idGoogle Cloud Project where the job is running
tolerancecertain metrics for tolerance
dataset_idThe dataset ID of the requested table. (templated)
table_idThe table ID of the requested table. (templated)
poll_intervalpolling period in seconds to check for the status
Documentation
BigQueryValueCheckTrigger run on the trigger worker, inherits from BigQueryInsertJobTrigger class