merge a bunch so the result is always the same (doesn't change based on what partition it decides to merge)

Author: danthegoodman1

examples/custom-merge-replacing.py

@@ -179,6 +179,13 @@ def part_func(row: dict) -> str:
 print("============= merging =============")
 # here we reduce the rows to a single latest row
 merged_log, new_file, partition, merged_files, meta = ice.merge()
+merged_log, new_file, partition, merged_files, meta = ice.merge()
+# redundant merges do nothing
+merged_log, new_file, partition, merged_files, meta = ice.merge()
+merged_log, new_file, partition, merged_files, meta = ice.merge()
+merged_log, new_file, partition, merged_files, meta = ice.merge()
+merged_log, new_file, partition, merged_files, meta = ice.merge()
+merged_log, new_file, partition, merged_files, meta = ice.merge()
 print(f"merged {len(merged_files)} data files from partition {partition}")
 
 print("============= check number of raw rows in data =============")