diff --git a/dlt/destinations/impl/bigquery/bigquery.py b/dlt/destinations/impl/bigquery/bigquery.py index c321c3ff2b..f1af10e7ac 100644 --- a/dlt/destinations/impl/bigquery/bigquery.py +++ b/dlt/destinations/impl/bigquery/bigquery.py @@ -223,7 +223,7 @@ def restore_file_load(self, file_path: str) -> LoadJob: return job def start_file_load(self, table: TTableSchema, file_path: str, load_id: str) -> LoadJob: - job = super().start_file_load(table, file_path, load_id) # type: ignore + job = super().start_file_load(table, file_path, load_id) if not job: insert_api = table.get("x-insert-api", "default") @@ -248,7 +248,7 @@ def start_file_load(self, table: TTableSchema, file_path: str, load_id: str) -> [], ) else: - job = BigQueryLoadJob( # type: ignore + job = BigQueryLoadJob( FileStorage.get_file_name_from_file_path(file_path), self._create_load_job(table, file_path), self.config.http_timeout, diff --git a/tests/load/bigquery/test_bigquery_streaming_insert.py b/tests/load/bigquery/test_bigquery_streaming_insert.py index b923ca7251..3ec385d670 100644 --- a/tests/load/bigquery/test_bigquery_streaming_insert.py +++ b/tests/load/bigquery/test_bigquery_streaming_insert.py @@ -37,5 +37,5 @@ def test_resource(): with pipe.sql_client() as client: with client.execute_query("SELECT * FROM test_streaming_items;") as cursor: res = cursor.fetchall() - assert res[0]["field1__nested_field"] == 1 - assert res[0]["field2__nested_field"] == 2 + assert res[0]["field1__nested_field"] == 1 # type: ignore + assert res[0]["field2__nested_field"] == 2 # type: ignore