Skip to content

Commit 9198cf4

Browse files
committed
address comments
1 parent af3b026 commit 9198cf4

1 file changed

Lines changed: 2 additions & 9 deletions

File tree

sdks/python/apache_beam/io/gcp/bigquery_file_loads.py

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -549,10 +549,7 @@ def process(
549549
'project', str, '') or self.project
550550
copy_from_references.append(copy_from_reference)
551551

552-
full_table_ref = '%s:%s.%s' % (
553-
copy_to_reference.projectId,
554-
copy_to_reference.datasetId,
555-
copy_to_reference.tableId)
552+
full_table_ref = bigquery_tools.get_hashable_destination(copy_to_reference)
556553

557554
is_first_time = full_table_ref not in self._observed_tables
558555
if is_first_time:
@@ -573,11 +570,7 @@ def process(
573570

574571
copy_job_name_base = '%s_%s' % (
575572
job_name_prefix,
576-
_bq_uuid(
577-
'%s:%s.%s' % (
578-
copy_to_reference.projectId,
579-
copy_to_reference.datasetId,
580-
copy_to_reference.tableId)))
573+
_bq_uuid(bigquery_tools.get_hashable_destination(copy_to_reference)))
581574

582575
project_id = (
583576
copy_to_reference.projectId

0 commit comments

Comments
 (0)