Skip to content

Commit 18d7e1e

Browse files
authored
Fix BigQuery system test (#18373)
1 parent ef0ff3f commit 18d7e1e

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -149,6 +149,7 @@
149149
"sourceFormat": "CSV",
150150
"compression": "NONE",
151151
"csvOptions": {"skipLeadingRows": 1},
152+
"sourceUris": [DATA_SAMPLE_GCS_URL],
152153
},
153154
},
154155
bucket=DATA_SAMPLE_GCS_BUCKET_NAME,

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

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,11 @@
155155
"query": {
156156
"query": f"SELECT * FROM {DATASET_NAME}.{TABLE_1}",
157157
"useLegacySql": False,
158-
"destinationTable": f"{DATASET_NAME}.{TABLE_2}",
158+
"destinationTable": {
159+
'projectId': PROJECT_ID,
160+
'datasetId': DATASET_NAME,
161+
'tableId': TABLE_2,
162+
},
159163
}
160164
},
161165
location=location,

0 commit comments

Comments
 (0)