remove_from_blocked_operations on fixed migrate operations, removed c…

…oncurrency value
vatesfr · Nov 27, 2024 · 54496e4 · 54496e4
1 parent a13f9ee
commit 54496e4
Showing 1 changed file with 8 additions and 15 deletions.
diff --git a/packages/xo-server/src/api/host.mjs b/packages/xo-server/src/api/host.mjs
@@ -24,22 +24,15 @@ export async function setMaintenanceMode({ host, maintenance, vmsToForceMigrate
   const xapi = this.getXapi(host)
 
   if (vmsToForceMigrate) {
-    await asyncEach(
-      vmsToForceMigrate,
-      async vmUuid => {
-        const record = await xapi.getRecordByUuid('VM', vmUuid)
-        const ref = record.$ref
-        const blockedOperations = record.blocked_operations
-        await Promise.all(
-          Object.keys(blockedOperations)
-            .filter(operation => ['pool_migrate', 'migrate_send'].includes(operation))
-            .map(async operation => await xapi.call('VM.remove_from_blocked_operations', ref, operation))
+    await asyncEach(vmsToForceMigrate, async vmUuid => {
+      const record = await xapi.getRecordByUuid('VM', vmUuid)
+      const ref = record.$ref
+      await Promise.all(
+        ['pool_migrate', 'migrate_send'].map(
+          async operation => await xapi.call('VM.remove_from_blocked_operations', ref, operation)
         )
-      },
-      {
-        concurrency: 4,
-      }
-    )
+      )
+    })
   }
 
   return maintenance ? xapi.clearHost(xapi.getObject(host)) : xapi.enableHost(host._xapiId)