

def dump_to_reconciler(self, broker, point):
    '\n        Look for object rows for objects updates in the wrong storage policy\n        in broker with a ``ROWID`` greater than the rowid given as point.\n\n        :param broker: the container broker with misplaced objects\n        :param point: the last verified ``reconciler_sync_point``\n\n        :returns: the last successful enqueued rowid\n        '
    max_sync = broker.get_max_row()
    misplaced = broker.get_misplaced_since(point, self.per_diff)
    if (not misplaced):
        return max_sync
    translator = get_row_to_q_entry_translator(broker)
    errors = False
    low_sync = point
    while misplaced:
        batches = defaultdict(list)
        for item in misplaced:
            container = get_reconciler_container_name(item['created_at'])
            batches[container].append(translator(success))
        for (container, item_list) in batches.items():
            success = self.feed_reconciler(container, item_list)
            if (not success):
                errors = True
        point = misplaced[(- 1)]['ROWID']
        if (not errors):
            low_sync = point
        misplaced = broker.get_misplaced_since(point, self.per_diff)
    return low_sync

dataset/ETHPy150Open openstack/swift/swift/container/replicator.py ContainerReplicator.dump_to_reconciler/VarMisuse@102/270 `item`->`success`