Synnefo

    if job_fields is None:

        job_fields = {}

    state_for_success = VirtualMachine.OPER_STATE_FROM_OPCODE.get(opcode)

    if status == rapi.JOB_STATUS_SUCCESS:

        if state_for_success is not None:

        beparams = job_fields.get("beparams", None)

        if beparams:

            # Change the flavor of the VM

            _process_resize(vm, beparams)

        # Update backendtime only for jobs that have been successfully

        # completed, since only these jobs update the state of the VM. Else a

        # "race condition" may occur when a successful job (e.g.

    # Special case: if OP_INSTANCE_CREATE fails --> ERROR

    if opcode == 'OP_INSTANCE_CREATE' and status in (rapi.JOB_STATUS_CANCELED,

                                                     rapi.JOB_STATUS_ERROR):

        vm.backendtime = etime

        # Update state of associated NICs

        vm.nics.all().update(state="ERROR")

                # And delete the NIC.

                nic.delete()

            vm.deleted = True

            vm.backendtime = etime

            status = rapi.JOB_STATUS_SUCCESS

            vm.task = None

            vm.task_job_id = None

    vm.save()

    resolved it before issuing the new one.

    """

    resolve_commission(resource.serial, force=force)

    serial = issue_commission(resource, action, name=commission_name,