'Ensure that reconciler databases are only cleaned up at the end of the
replication run.'

def delete_db(self, broker):

    if ((self.reconciler_cleanups is not None) and (broker.account == MISPLACED_OBJECTS_ACCOUNT)):
        self.reconciler_cleanups[broker.container] = broker
        return
    try:
        self.sync_store.remove_synced_container(broker)
    except Exception:
        self.logger.exception(('Failed    to    remove    sync_store    entry    %s' % broker.db_file))
    return super(ContainerReplicator, self).delete_db(broker)
