

def feed_reconciler(self, container, item_list):
    '\n        Add queue entries for rows in item_list to the local reconciler\n        container database.\n\n        :param container: the name of the reconciler container\n        :param item_list: the list of rows to enqueue\n\n        :returns: True if successfully enqueued\n        '
    try:
        reconciler = self.get_reconciler_broker(container)
    except DeviceUnavailable as e:
        self.logger.warning('DeviceUnavailable: %s', e)
        return False
    self.logger.debug('Adding %d objects to the reconciler at %s', len(item_list), reconciler.db_file)
    try:
        reconciler.merge_items(item_list)
    except (Exception, Timeout):
        self.logger.exception('UNHANDLED EXCEPTION: trying to merge %d items to reconciler container %s', len(item_list), reconciler.db_file)
        return False
    return True

dataset/ETHPy150Open openstack/swift/swift/container/replicator.py ContainerReplicator.feed_reconciler/original