code: def assign_to_a_queue(self, action):
          
          (worker_id, queue) = self._get_queue_for_the_action(action)
          if not worker_id:
              return
  
          # Tag the action as "in the worker i"
          action.my_worker = worker_id
          action.status = ACT_STATUS_QUEUED
  
          msg = Message(_type='Do', data=action, source=self.name)
          logger.debug("Queuing message: %s", msg)
          queue.put_nowait(msg)
          logger.debug("Queued")
docs: Take an action and put it to a worker actions queue
  
          :param action: action to put
          :type action: alignak.action.Action
          :return: None