code: def feed_backend_arthur(backend_name, backend_params):
      
  
      # Always get pending items from arthur for all data sources
      feed_arthur()
  
      logger.debug("Items available for %s", arthur_items.keys())
  
      # Get only the items for the backend
      if not get_connector_from_name(backend_name):
          raise RuntimeError("Unknown backend %s" % backend_name)
      connector = get_connector_from_name(backend_name)
      klass = connector[3]  # BackendCmd for the connector
  
      backend_cmd = init_backend(klass(*backend_params))
  
      tag = backend_cmd.backend.tag
      logger.debug("Getting items for %s.", tag)
  
      if tag in arthur_items:
          logger.debug("Found items for %s.", tag)
          for item in arthur_items[tag]:
              yield item
docs: Feed Ocean with backend data collected from arthur redis queue