docs: def finalize_concurrency_state(self, outcome):
          """ Utility function to finalize the forward execution of the concurrency state.
  
          :param outcome:
          :return:
          """
          final_outcome = outcome
          self.write_output_data()
          self.check_output_data_type()
          self.execution_history.push_return_history_item(self, CallType.CONTAINER, self, self.output_data)
          self.state_execution_status = StateExecutionStatus.WAIT_FOR_NEXT_STATE
  
          singleton.state_machine_execution_engine._modify_run_to_states(self)
  
          if self.preempted:
              final_outcome = Outcome(-2, "preempted")
          return self.finalize(final_outcome)