def next_state()

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,
        )