docs: def _run_active_state_machine(self):
          """Store running state machine and observe its status
          """
  
          # Create new concurrency queue for root state to be able to synchronize with the execution
          self.__running_state_machine = self.state_machine_manager.get_active_state_machine()
          if not self.__running_state_machine:
              logger.error("The running state machine must not be None")
          self.__running_state_machine.root_state.concurrency_queue = queue.Queue(maxsize=0)
  
          if self.__running_state_machine:
              self.__running_state_machine.start()
  
              self.__wait_for_finishing_thread = threading.Thread(target=self._wait_for_finishing)
              self.__wait_for_finishing_thread.start()
          else:
              logger.warning("Currently no active state machine! Please create a new state machine.")
              self.set_execution_mode(StateMachineExecutionStatus.STOPPED)