code: def enqueue_command(self, command, data):
          
          if command == CommandType.TrialEnd or (command == CommandType.ReportMetricData and data['type'] == 'PERIODICAL'):
              self.assessor_command_queue.put((command, data))
          else:
              self.default_command_queue.put((command, data))
  
          qsize = self.default_command_queue.qsize()
          if qsize >= QUEUE_LEN_WARNING_MARK:
              _logger.warning('default queue length: %d', qsize)
  
          qsize = self.assessor_command_queue.qsize()
          if qsize >= QUEUE_LEN_WARNING_MARK:
              _logger.warning('assessor queue length: %d', qsize)
docs: Enqueue command into command queues