Skip to content

Commit 25f6552

Browse files
authored
input is reshuffled so we can't guarantee that same input row will get specific job id based on which we have assert. (#36402)
1 parent 0b9fe99 commit 25f6552

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -891,7 +891,7 @@ def dynamic_destination_resolver(element, *side_inputs):
891891
Mock(jobReference=bigquery_api.JobReference(jobId=f'job_name{i}'))
892892
# Order matters in a sense to prove that jobs with different ids
893893
# (`2` & `3`) are run with `WRITE_APPEND` without this current fix.
894-
for i in [1, 2, 1, 3, 1]
894+
for i in [1, 1, 1, 1, 1]
895895
]
896896
mock_perform_start_job.side_effect = mock_jobs
897897

@@ -955,7 +955,7 @@ def dynamic_destination_resolver(element, *side_inputs):
955955
TableReference(
956956
datasetId='dataset1',
957957
projectId='project1',
958-
tableId='job_name2'),
958+
tableId='job_name1'),
959959
TableReference(
960960
datasetId='dataset1',
961961
projectId='project1',
@@ -984,7 +984,7 @@ def dynamic_destination_resolver(element, *side_inputs):
984984
TableReference(
985985
datasetId='dataset3',
986986
projectId='project1',
987-
tableId='job_name3'),
987+
tableId='job_name1'),
988988
TableReference(
989989
datasetId='dataset3',
990990
projectId='project1',

0 commit comments

Comments
 (0)