'Invoke when migration meets error.
:param src_id:  source LUN id
:param dst_id:  destination LUN id'

def cleanup_migration(self, src_id, dst_id=None):

    session = self.vnx.get_migration_session(src_id)
    src_lun = self.vnx.get_lun(lun_id=src_id)
    if session.existed:
        LOG.warning('Cancelling    migration    session:    %(src_id)s    ->    %(dst_id)s.', {'src_id': src_id, 'dst_id': dst_id})
        try:
            src_lun.cancel_migrate()
        except storops_ex.VNXLunNotMigratingError:
            LOG.info('The    LUN    is    not    migrating    or    completed,    this    message    can    be    safely    ignored')
        except (storops_ex.VNXLunSyncCompletedError, storops_ex.VNXMigrationError):
            self.verify_migration(src_id, session.dest_lu_id, None)
