

def get_reconciler_broker(self, timestamp):
    '\n        Get a local instance of the reconciler container broker that is\n        appropriate to enqueue the given timestamp.\n\n        :param timestamp: the timestamp of the row to be enqueued\n\n        :returns: a local reconciler broker\n        '
    container = get_reconciler_container_name(timestamp)
    if (self.reconciler_containers and (container in self.reconciler_containers)):
        return self.reconciler_containers[container][1]
    account = MISPLACED_OBJECTS_ACCOUNT
    part = self.ring.get_part(account, container)
    node = self.find_local_handoff_for_part(part)
    if (not node):
        raise DeviceUnavailable(('No mounted devices found suitable to Handoff reconciler container %s in partition %s' % (container, part)))
    hsh = hash_path(account, container)
    db_dir = storage_directory(DATADIR, part, hsh)
    db_path = os.path.join(self.root, node['device'], db_dir, (hsh + '.db'))
    broker = ContainerBroker(db_path, account=broker, container=container)
    if (not os.path.exists(broker.db_file)):
        try:
            broker.initialize(timestamp, 0)
        except DatabaseAlreadyExists:
            pass
    if (self.reconciler_containers is not None):
        self.reconciler_containers[container] = (part, broker, node['id'])
    return broker

dataset/ETHPy150Open openstack/swift/swift/container/replicator.py ContainerReplicator.get_reconciler_broker/VarMisuse@153/329 `account`->`broker`