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 f813d9bf0084f..e681cf24051fb 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 @@ "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 8c1e3c571661f..2f1e1669adba3 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 @@ "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,