Add autodetect arg to external table creation in GCSToBigQueryOperator (

#21944) * Added autodetect parameter in external table creation in GCSToBigQueryOperator
apache · Mar 6, 2022 · 9020b3a · 9020b3a
1 parent 26e8d6d
commit 9020b3a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/airflow/providers/google/cloud/transfers/gcs_to_bigquery.py b/airflow/providers/google/cloud/transfers/gcs_to_bigquery.py
@@ -273,6 +273,7 @@ def execute(self, context: 'Context'):
  schema_fields=schema_fields,
  source_uris=source_uris,
  source_format=self.source_format,
+ autodetect=self.autodetect,
  compression=self.compression,
  skip_leading_rows=self.skip_leading_rows,
  field_delimiter=self.field_delimiter,

diff --git a/tests/providers/google/cloud/transfers/test_gcs_to_bigquery.py b/tests/providers/google/cloud/transfers/test_gcs_to_bigquery.py
@@ -146,6 +146,7 @@ def test_labels_external_table(self, bq_hook):
  schema_fields=mock.ANY,
  source_uris=mock.ANY,
  source_format=mock.ANY,
+ autodetect=mock.ANY,
  compression=mock.ANY,
  skip_leading_rows=mock.ANY,
  field_delimiter=mock.ANY,
@@ -181,6 +182,7 @@ def test_description_external_table(self, bq_hook):
  schema_fields=mock.ANY,
  source_uris=mock.ANY,
  source_format=mock.ANY,
+ autodetect=mock.ANY,
  compression=mock.ANY,
  skip_leading_rows=mock.ANY,
  field_delimiter=mock.ANY,