[AIRFLOW-6977] Fix BigQuery DTS example DAG (#7612)

turbaszek · web-flow · commit 09fea3ce8e4d · 2020-03-04T13:44:37.000+01:00
diff --git a/airflow/providers/google/cloud/example_dags/example_bigquery_dts.py b/airflow/providers/google/cloud/example_dags/example_bigquery_dts.py
@@ -28,6 +28,7 @@
 from airflow import models
 from airflow.providers.google.cloud.operators.bigquery_dts import (
     BigQueryCreateDataTransferOperator, BigQueryDataTransferServiceStartTransferRunsOperator,
+    BigQueryDeleteDataTransferConfigOperator,
 )
 from airflow.providers.google.cloud.sensors.bigquery_dts import BigQueryDataTransferServiceTransferRunSensor
 from airflow.utils.dates import days_ago
@@ -110,7 +111,7 @@
     # [END howto_bigquery_dts_sensor]
 
     # [START howto_bigquery_delete_data_transfer]
-    gcp_bigquery_delete_transfer = BigQueryDataTransferServiceStartTransferRunsOperator(
+    gcp_bigquery_delete_transfer = BigQueryDeleteDataTransferConfigOperator(
         transfer_config_id=transfer_config_id, task_id="gcp_bigquery_delete_transfer"
     )
     # [END howto_bigquery_delete_data_transfer]
