From f4249b6d4d10b5d407823620ab3a6923e1e52232 Mon Sep 17 00:00:00 2001 From: Pierce Faraone Date: Fri, 18 Oct 2024 17:09:29 -0700 Subject: [PATCH] Added additional logging --- deltacat/compute/compactor_v2/deletes/utils.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/deltacat/compute/compactor_v2/deletes/utils.py b/deltacat/compute/compactor_v2/deletes/utils.py index 1b7b9b86..d41d6d71 100644 --- a/deltacat/compute/compactor_v2/deletes/utils.py +++ b/deltacat/compute/compactor_v2/deletes/utils.py @@ -147,10 +147,11 @@ def prepare_deletes( """ if not input_deltas: return PrepareDeleteResult(input_deltas, [], None) + logger.info(f"Preparing deletes for Partition-{params.source_partition_locator}") assert all( input_deltas[i].stream_position <= input_deltas[i + 1].stream_position for i in range(len(input_deltas) - 1) - ), "Uniform deltas must be in non-decreasing order by stream position" + ), f"Uniform deltas of length: {len(input_deltas)} must be in non-decreasing order by stream position" start_stream_spos_to_delete_delta_sequence: Dict[ int, List[Delta] ] = _aggregate_delete_deltas(input_deltas)