From a42f0faaae55c04439c49f9338e12504675aede3 Mon Sep 17 00:00:00 2001 From: claudevdm <33973061+claudevdm@users.noreply.github.com> Date: Thu, 1 May 2025 18:13:29 -0400 Subject: [PATCH] Add name to BQ File Loads lambda to ensure changes are update compatible (#34807) * Add name to bq lambda. * Add comment. --------- Co-authored-by: Claude --- sdks/python/apache_beam/io/gcp/bigquery_file_loads.py | 5 ++++- 1 file changed, 4 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..997bb19634a6 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,10 @@ 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 + # This name is to ensure update compat. + | "Map()" >> + beam.Map(lambda x: [x])) copy_job_outputs = ( finished_temp_tables_load_job_ids_list_pc