You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2021/09/20 22:46:04 UTC
[airflow] branch main updated: Fix BigQuery system test (#18373)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 18d7e1e Fix BigQuery system test (#18373)
18d7e1e is described below
commit 18d7e1e2270ffcbc8077ba700f209ae69eccef99
Author: deedmitrij <de...@gmail.com>
AuthorDate: Tue Sep 21 01:45:45 2021 +0300
Fix BigQuery system test (#18373)
---
.../google/cloud/example_dags/example_bigquery_operations.py | 1 +
.../providers/google/cloud/example_dags/example_bigquery_queries.py | 6 +++++-
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/airflow/providers/google/cloud/example_dags/example_bigquery_operations.py b/airflow/providers/google/cloud/example_dags/example_bigquery_operations.py
index f813d9b..e681cf2 100644
--- a/airflow/providers/google/cloud/example_dags/example_bigquery_operations.py
+++ b/airflow/providers/google/cloud/example_dags/example_bigquery_operations.py
@@ -149,6 +149,7 @@ with models.DAG(
"sourceFormat": "CSV",
"compression": "NONE",
"csvOptions": {"skipLeadingRows": 1},
+ "sourceUris": [DATA_SAMPLE_GCS_URL],
},
},
bucket=DATA_SAMPLE_GCS_BUCKET_NAME,
diff --git a/airflow/providers/google/cloud/example_dags/example_bigquery_queries.py b/airflow/providers/google/cloud/example_dags/example_bigquery_queries.py
index 8c1e3c5..2f1e166 100644
--- a/airflow/providers/google/cloud/example_dags/example_bigquery_queries.py
+++ b/airflow/providers/google/cloud/example_dags/example_bigquery_queries.py
@@ -155,7 +155,11 @@ for location in [None, LOCATION]:
"query": {
"query": f"SELECT * FROM {DATASET_NAME}.{TABLE_1}",
"useLegacySql": False,
- "destinationTable": f"{DATASET_NAME}.{TABLE_2}",
+ "destinationTable": {
+ 'projectId': PROJECT_ID,
+ 'datasetId': DATASET_NAME,
+ 'tableId': TABLE_2,
+ },
}
},
location=location,