code: def run(self):
          
          try:
              self.proxy = config_ini.engine.open()
  
              # Get items from 'pyrotorque' view
              items = list(config_ini.engine.items(self.VIEWNAME, cache=False))
  
              if self.sort_key:
                  items.sort(key=self.sort_key)
                  #self.LOG.debug("Sorted: %r" % [i.name for i in items])
  
              # Handle found items
              self._start(items)
              self.LOG.debug("%s - %s" % (config_ini.engine.engine_id, self.proxy))
          except (error.LoggableError, xmlrpc.ERRORS) as exc:
              # only debug, let the statistics logger do its job
              self.LOG.debug(str(exc))
docs: Queue manager job callback.