Skip to content

Commit

Permalink
lint fix
Browse files Browse the repository at this point in the history
  • Loading branch information
IlyaFaer committed Mar 28, 2024
1 parent f3c5068 commit 0ff0ea6
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions dlt/destinations/impl/bigquery/bigquery.py
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand All @@ -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,
Expand Down
4 changes: 2 additions & 2 deletions tests/load/bigquery/test_bigquery_streaming_insert.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

0 comments on commit 0ff0ea6

Please sign in to comment.