'Ensure any items merged to reconciler containers during replication
are pushed out to correct nodes and any reconciler containers that do
not belong on this node are removed.'

def replicate_reconcilers(self):

    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
    self.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')
