in message_flow/sagas/orchestration_simple_dsl/saga_execution_state.py [0:0]
def next_state(self, size: int) -> "SagaExecutionState":
return SagaExecutionState(
self.currently_executing - size
if self.compensating
else self.currently_executing + size,
self.compensating,
)