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(<lambda at bigquery_file_loads.py:1157>)" >>
+          beam.Map(lambda x: [x]))
 
     copy_job_outputs = (
         finished_temp_tables_load_job_ids_list_pc