We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7ca3068 commit 398b322Copy full SHA for 398b322
1 file changed
sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
@@ -1166,7 +1166,10 @@ def _load_data(
1166
else:
1167
# Loads can happen in parallel.
1168
finished_temp_tables_load_job_ids_list_pc = (
1169
- finished_temp_tables_load_job_ids_pc | beam.Map(lambda x: [x]))
+ finished_temp_tables_load_job_ids_pc
1170
+ # This name is to ensure update compat.
1171
+ | "Map(<lambda at bigquery_file_loads.py:1157>)" >>
1172
+ beam.Map(lambda x: [x]))
1173
1174
copy_job_outputs = (
1175
finished_temp_tables_load_job_ids_list_pc
0 commit comments