[airflow] branch main updated: Fix BigQuery system test (#18373)

[potiuk]

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 <deedmit...@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,