'Force live migration to complete.
:param context: Security context
:param instance: The instance that is being migrated
:param migration_id: ID of ongoing migration'

@check_instance_lock
@check_instance_cell
@check_instance_state(vm_state=[vm_states.ACTIVE], task_state=[task_states.MIGRATING])
def live_migrate_force_complete(self, context, instance, migration_id):

    LOG.debug('Going    to    try    to    force    live    migration    to    complete', instance=instance)
    migration = objects.Migration.get_by_id_and_instance(context, migration_id, instance.uuid)
    if (migration.status != 'running'):
        raise exception.InvalidMigrationState(migration_id=migration_id, instance_uuid=instance.uuid, state=migration.status, method='force    complete')
    self._record_action_start(context, instance, instance_actions.LIVE_MIGRATION_FORCE_COMPLETE)
    self.compute_rpcapi.live_migration_force_complete(context, instance, migration)
