@@ -628,20 +628,20 @@ def _build_rewind_audit_receipt(
628628 events_after = session .events [:rewind_event_index ]
629629 boundary_after_invocation_id = None
630630 if rewind_event_index > 0 :
631- boundary_after_invocation_id = (
632- session . events [ rewind_event_index - 1 ]. invocation_id
633- )
631+ boundary_after_invocation_id = session . events [
632+ rewind_event_index - 1
633+ ]. invocation_id
634634
635635 history_before_hash = self ._hash_rewind_events (events_before )
636636 history_after_hash = self ._hash_rewind_events (events_after )
637637
638638 receipt_payload = {
639- 'rewind_before_invocation_id' : rewind_before_invocation_id ,
640- 'boundary_after_invocation_id' : boundary_after_invocation_id ,
641- 'events_before_rewind' : len (events_before ),
642- 'events_after_rewind' : len (events_after ),
643- 'history_before_hash' : history_before_hash ,
644- 'history_after_hash' : history_after_hash ,
639+ 'rewind_before_invocation_id' : rewind_before_invocation_id ,
640+ 'boundary_after_invocation_id' : boundary_after_invocation_id ,
641+ 'events_before_rewind' : len (events_before ),
642+ 'events_after_rewind' : len (events_after ),
643+ 'history_before_hash' : history_before_hash ,
644+ 'history_after_hash' : history_after_hash ,
645645 }
646646 receipt_hash = self ._hash_rewind_payload (receipt_payload )
647647
@@ -659,18 +659,16 @@ def _hash_rewind_events(self, events: List[Event]) -> str:
659659 """Hashes event summaries for deterministic rewind audit receipts."""
660660 summarized_events = []
661661 for event in events :
662- summarized_events .append (
663- {
664- 'event_id' : event .id ,
665- 'invocation_id' : event .invocation_id ,
666- 'author' : event .author ,
667- 'state_delta' : event .actions .state_delta ,
668- 'artifact_delta' : event .actions .artifact_delta ,
669- 'rewind_before_invocation_id' : (
670- event .actions .rewind_before_invocation_id
671- ),
672- }
673- )
662+ summarized_events .append ({
663+ 'event_id' : event .id ,
664+ 'invocation_id' : event .invocation_id ,
665+ 'author' : event .author ,
666+ 'state_delta' : event .actions .state_delta ,
667+ 'artifact_delta' : event .actions .artifact_delta ,
668+ 'rewind_before_invocation_id' : (
669+ event .actions .rewind_before_invocation_id
670+ ),
671+ })
674672 return self ._hash_rewind_payload ({'events' : summarized_events })
675673
676674 def _hash_rewind_payload (self , payload : dict [str , Any ]) -> str :
0 commit comments