vmware_vmotion - find an placement recommendation 10 times every 1 minute

changelogs/fragments/1735-vmware_vmotion.yaml

@@ -0,0 +1,4 @@
+---
+minor_changes:
+  - vmware_vmotion - Add the function that it trys to find an placement recommendation 10 times every 1 minute
+    (https://github.com/ansible-collections/community.vmware/pull/1735)

plugins/modules/vmware_vmotion.py

@@ -10,7 +10,6 @@
 from __future__ import absolute_import, division, print_function
 __metaclass__ = type
 
-
 DOCUMENTATION = r'''
 ---
 module: vmware_vmotion
@@ -169,6 +168,8 @@
 except ImportError:
     pass
 
+import time
+
 from ansible.module_utils._text import to_native
 from ansible.module_utils.basic import AnsibleModule
 from ansible_collections.community.vmware.plugins.module_utils.vmware import (
@@ -472,16 +473,27 @@ def set_placement(self):
             storagePods = [self.datastore_cluster_object]
         else:
             storagePods = None
-        placement_spec = vim.cluster.PlacementSpec(storagePods=storagePods,
-                                                   hosts=self.cluster_hosts,
-                                                   vm=self.vm,
-                                                   relocateSpec=relocate_spec)
-        placement = self.cluster_object.PlaceVm(placement_spec)
-
-        if self.host_object is None:
-            self.host_object = placement.recommendations[0].action[0].targetHost
-        if self.datastore_object is None:
-            self.datastore_object = placement.recommendations[0].action[0].relocateSpec.datastore
+
+        if self.host_object is None or self.datastore_object is None:
+            placement_spec = vim.cluster.PlacementSpec(storagePods=storagePods,
+                                                       hosts=self.cluster_hosts,
+                                                       vm=self.vm,
+                                                       relocateSpec=relocate_spec)
+            placement = self.cluster_object.PlaceVm(placement_spec)
+
+            counter = 0  # Try it 10 times every minute
+            while len(placement.recommendations) < 1:
+                if counter == 10:
+                    vm_id = self.vm_uuid or self.vm_name or self.moid
+                    self.module.fail_json(msg="Failed to find a placement recommendation for vm: %s" % vm_id)
+                counter = counter + 1
+                time.sleep(60)
+                placement = self.cluster_object.PlaceVm(placement_spec)
+
+            if self.host_object is None:
+                self.host_object = placement.recommendations[0].action[0].targetHost
+            if self.datastore_object is None:
+                self.datastore_object = placement.recommendations[0].action[0].relocateSpec.datastore
 
     def get_vm(self):
         """