You need to create a SQL pipeline. The pipeline runs an aggregate SQL transformation on a BigQuery table every two hours and appends the result to another existing BigQuery table. You need to configure the pipeline to retry if errors occur. You want the pipeline to send an email notification after three consecutive failures. What should you do?

A is not correct because BigQuery scheduled query does not have retry options. B is not correct because BigQueryUpsertTableOperator is used to create/update table properties and not to run SQL transformation. C is not correct because BigQuery scheduled query does not have retry options even though custom notification logic can be built as a Cloud Run function. D is correct because the BigQueryInsertJobOperator operator can run sql transformation queries on a BigQuery table and append the results to another BigQuery table. With retry=3 and email_on_failure=True, the operator retries 3 times and then sends email notification if all the 3 retries are exhausted