

def replicate_reconcilers(self):
    '\n        Ensure any items merged to reconciler containers during replication\n        are pushed out to correct nodes and any reconciler containers that do\n        not belong on this node are removed.\n        '
    self.logger.info('Replicating %d reconciler containers', len(self.reconciler_containers))
    for (part, reconciler, node_id) in self.reconciler_containers.values():
        self.cpool.spawn_n(self._replicate_object, part, reconciler.db_file, node_id)
    self.cpool.waitall()
    cleanups = self.reconciler_cleanups
    self.reconciler_cleanups = self.reconciler_containers = None
    cleanups.logger.info('Cleaning up %d reconciler containers', len(cleanups))
    for reconciler in cleanups.values():
        self.cpool.spawn_n(self.delete_db, reconciler)
    self.cpool.waitall()
    self.logger.info('Finished reconciler replication')

dataset/ETHPy150Open openstack/swift/swift/container/replicator.py ContainerReplicator.replicate_reconcilers/VarMisuse@91/213 `self`->`cleanups`