diff --git a/src/proto_alpha/lib_protocol/dal_slot_storage.ml b/src/proto_alpha/lib_protocol/dal_slot_storage.ml index f04bc3bf354b8da727f84672e39abe12281f37cc..699577121df3eec2ee83ea3d7c3538e6e9dbe9dd 100644 --- a/src/proto_alpha/lib_protocol/dal_slot_storage.ml +++ b/src/proto_alpha/lib_protocol/dal_slot_storage.ml @@ -73,7 +73,8 @@ let finalize_pending_slot_headers ctxt ~number_of_slots = match Raw_level_repr.(sub raw_level dal.attestation_lag) with | None -> return (ctxt, Dal_attestation_repr.empty) | Some level_attested -> - let* seen_slots = Storage.Dal.Slot.Headers.find ctxt level_attested in + let* seen_slots = find_slot_headers ctxt level_attested in + let*! ctxt = Storage.Dal.Slot.Headers.remove ctxt level_attested in let* ctxt, attestation, confirmed_slot_headers = match seen_slots with | None -> return (ctxt, Dal_attestation_repr.empty, []) @@ -82,7 +83,6 @@ let finalize_pending_slot_headers ctxt ~number_of_slots = compute_attested_slot_headers ctxt seen_slots in let attested_slot_headers = List.rev rev_attested_slot_headers in - let*! ctxt = Storage.Dal.Slot.Headers.remove ctxt level_attested in return (ctxt, attestation, attested_slot_headers) in let* ctxt =