From 545566dfb0a9628691a9eb85fe1b79d0f2d234e7 Mon Sep 17 00:00:00 2001 From: Claude Date: Thu, 1 May 2025 20:07:25 +0000 Subject: [PATCH 1/2] Add name to bq lambda. --- sdks/python/apache_beam/io/gcp/bigquery_file_loads.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py b/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py index 2f0375859235..4d642449c5c1 100644 --- a/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py +++ b/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py @@ -1166,7 +1166,9 @@ def _load_data( else: # Loads can happen in parallel. finished_temp_tables_load_job_ids_list_pc = ( - finished_temp_tables_load_job_ids_pc | beam.Map(lambda x: [x])) + finished_temp_tables_load_job_ids_pc + | "Map()" >> + beam.Map(lambda x: [x])) copy_job_outputs = ( finished_temp_tables_load_job_ids_list_pc From 531bcbc630c2e1d3bbec547ec463db0535f5b502 Mon Sep 17 00:00:00 2001 From: Claude Date: Thu, 1 May 2025 20:44:11 +0000 Subject: [PATCH 2/2] Add comment. --- sdks/python/apache_beam/io/gcp/bigquery_file_loads.py | 1 + 1 file changed, 1 insertion(+) diff --git a/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py b/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py index 4d642449c5c1..997bb19634a6 100644 --- a/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py +++ b/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py @@ -1167,6 +1167,7 @@ def _load_data( # Loads can happen in parallel. finished_temp_tables_load_job_ids_list_pc = ( finished_temp_tables_load_job_ids_pc + # This name is to ensure update compat. | "Map()" >> beam.Map(lambda x: [x]))