# ... API init


vms= api.vms.list(query = 'vmname')


for vm in vms:


  print vm.name


  for disk in vm.disks.list( ):


    print " disk: " + disk.name + " " + disk.get_alias()


    sd = api.storagedomains.get('NEWSTORAGE')


    try:


      disk.move(params.Action(storage_domain=sd))


      disk_id = disk.get_id()


      while True:


          print("Waiting for movement to complete ...")


          time.sleep(10)


          disk = vm.disks.get(id=disk_id)


          if disk.get_status().get_state() == "ok":


              break


    except:


      print "Cannot move."


api.disconnect()