Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit 4c5f765

Browse files
committed
Small fix for PR in Bigquery
1 parent d381e99 commit 4c5f765

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

data_diff/sqeleton/databases/bigquery.py

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -159,16 +159,15 @@ def _normalize_table_path(self, path: DbPath) -> DbPath:
159159
if len(path) == 0:
160160
raise ValueError(f"{self.name}: Bad table path for {self}: ()")
161161
elif len(path) == 1:
162-
if self.default_schema:
163-
return [self.project, self.default_schema, path[0]]
164-
else:
165-
return path
162+
return (self.project, self.default_schema, path[0])
166163
elif len(path) == 2:
167-
return [self.project] + path
164+
return (self.project,) + path
168165
elif len(path) == 3:
169166
return path
170167
else:
171-
raise ValueError(f"{self.name}: Bad table path for {self}: '{'.'.join(path)}'. Expected form: [project.]schema.table")
168+
raise ValueError(
169+
f"{self.name}: Bad table path for {self}: '{'.'.join(path)}'. Expected form: [project.]schema.table"
170+
)
172171

173172
def parse_table_name(self, name: str) -> DbPath:
174173
path = parse_table_name(name)

0 commit comments

Comments
 (0)