Skip to content

Commit 1319c1a

Browse files
Refactor
1 parent a6631e1 commit 1319c1a

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

pybigquery/sqlalchemy_bigquery.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -363,13 +363,15 @@ def _split_table_name(full_table_name):
363363
dataset, table_name = table_name_split
364364
elif len(table_name_split) == 3:
365365
project, dataset, table_name = table_name_split
366+
# TODO: Get a test for an else statement here
366367

367368
return (project, dataset, table_name)
368369

369370
def _table_reference(self, provided_schema_name, provided_table_name,
370371
client_project):
371372
project_id_from_table, dataset_id_from_table, table_id = self._split_table_name(provided_table_name)
372373
project_id_from_schema = None
374+
dataset_id_from_schema = None
373375
if provided_schema_name is not None:
374376
provided_schema_name_split = provided_schema_name.split('.')
375377
if len(provided_schema_name_split) == 0:
@@ -378,12 +380,12 @@ def _table_reference(self, provided_schema_name, provided_table_name,
378380
if dataset_id_from_table:
379381
project_id_from_schema = provided_schema_name_split[0]
380382
else:
381-
pass # TODO: write a test case
383+
dataset_id_from_schema = provided_schema_name_split[0]
382384
elif len(provided_schema_name_split) == 2:
383385
pass
384386
# TODO: Get a test for an else statement here
385387
project_id = project_id_from_schema or project_id_from_table or client_project
386-
dataset_id = dataset_id_from_table or provided_schema_name or self.dataset_id
388+
dataset_id = dataset_id_from_schema or dataset_id_from_table or self.dataset_id
387389

388390
table_ref = TableReference.from_string("{}.{}.{}".format(
389391
project_id, dataset_id, table_id

0 commit comments

Comments
 (0)