Skip to content

Commit faf0df4

Browse files
authored
[AIRFLOW-XXXX] Fix upsert operator in BQ example DAG (#7666)
1 parent b39468d commit faf0df4

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
Example Airflow DAG for Google BigQuery service.
2121
"""
2222
import os
23+
import time
2324
from urllib.parse import urlparse
2425

2526
from airflow import models
@@ -256,9 +257,9 @@
256257
update_table = BigQueryUpsertTableOperator(
257258
task_id="update_table", dataset_id=DATASET_NAME, table_resource={
258259
"tableReference": {
259-
"tableId": "test-table-id"
260+
"tableId": "test_table_id"
260261
},
261-
"expirationTime": 12345678
262+
"expirationTime": (int(time.time()) + 300) * 1000
262263
}
263264
)
264265

0 commit comments

Comments
 (0)