Skip to content

Commit 09fea3c

Browse files
authored
[AIRFLOW-6977] Fix BigQuery DTS example DAG (#7612)
1 parent a6e5bcd commit 09fea3c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

β€Žairflow/providers/google/cloud/example_dags/example_bigquery_dts.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
from airflow import models
2929
from airflow.providers.google.cloud.operators.bigquery_dts import (
3030
BigQueryCreateDataTransferOperator, BigQueryDataTransferServiceStartTransferRunsOperator,
31+
BigQueryDeleteDataTransferConfigOperator,
3132
)
3233
from airflow.providers.google.cloud.sensors.bigquery_dts import BigQueryDataTransferServiceTransferRunSensor
3334
from airflow.utils.dates import days_ago
@@ -110,7 +111,7 @@
110111
# [END howto_bigquery_dts_sensor]
111112

112113
# [START howto_bigquery_delete_data_transfer]
113-
gcp_bigquery_delete_transfer = BigQueryDataTransferServiceStartTransferRunsOperator(
114+
gcp_bigquery_delete_transfer = BigQueryDeleteDataTransferConfigOperator(
114115
transfer_config_id=transfer_config_id, task_id="gcp_bigquery_delete_transfer"
115116
)
116117
# [END howto_bigquery_delete_data_transfer]

0 commit comments

Comments
 (0)