in message_flow/sagas/orchestration/saga_manager_impl.py [0:0]
def _perform_end_state_actions(
self,
saga_id: str,
saga_instance: SagaInstance,
compensating: bool,
failed: bool,
saga_data: Data,