BigQueryInsertJobTrigger
Astronomer ProvidersBigQueryInsertJobTrigger run on the trigger worker to perform insert operation
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
conn_idReference to google cloud connection id
job_idThe ID of the job. It will be suffixed with hash of job configuration
project_idGoogle Cloud Project where the job is running
dataset_idThe dataset ID of the requested table. (templated)
table_idThe table ID of the requested table. (templated)
delegate_toThis performs a task on one host with reference to other hosts.
impersonation_chainThis is the optional service account to impersonate using short term credentials.
poll_intervalpolling period in seconds to check for the status
Documentation
BigQueryInsertJobTrigger run on the trigger worker to perform insert operation