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

[po...@apache.org]

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 e840acf  Fix BigQuery system test (#21320)
e840acf is described below

commit e840acf8d1840761b72b596ccd4280efece0c974
Author: Maksim <ma...@google.com>
AuthorDate: Fri Feb 4 15:21:09 2022 +0000

    Fix BigQuery system test (#21320)
---
 .../google/cloud/example_dags/example_bigquery_operations.py          | 2 +-
 airflow/providers/google/cloud/operators/bigquery.py                  | 4 ++++
 2 files changed, 5 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 0ae5213..d12a749 100644
--- a/airflow/providers/google/cloud/example_dags/example_bigquery_operations.py
+++ b/airflow/providers/google/cloud/example_dags/example_bigquery_operations.py
@@ -193,7 +193,7 @@ with models.DAG(
         task_id="update_table",
         dataset_id=DATASET_NAME,
         table_id="test_table",
-        fields=["emp_name", "salary"],
+        fields=["friendlyName", "description"],
         table_resource={
             "friendlyName": "Updated Table",
             "description": "Updated Table",
diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py
index abd2b8b..9338594 100644
--- a/airflow/providers/google/cloud/operators/bigquery.py
+++ b/airflow/providers/google/cloud/operators/bigquery.py
@@ -1079,6 +1079,10 @@ class BigQueryCreateExternalTableOperator(BaseOperator):
             self.table_resource = None
         else:
             self.table_resource = table_resource
+            self.bucket = ""
+            self.source_objects = []
+            self.schema_object = None
+            self.destination_project_dataset_table = ""
 
         if table_resource and kwargs_passed:
             raise ValueError("You provided both `table_resource` and exclusive keywords arguments.")