mgr/cephadm: use asyncio.gather to parallelize things

Signed-off-by: Sebastian Wagner <sewagner@redhat.com>

diff --git a/src/pybind/mgr/cephadm/services/osd.py b/src/pybind/mgr/cephadm/services/osd.py
index 50011b6b2d4f69a93238ca2a9816da8e7d310c02..c8e9682f23444bd9701e48258918bb0f032b632b 100644 (file)
--- a/src/pybind/mgr/cephadm/services/osd.py
+++ b/src/pybind/mgr/cephadm/services/osd.py
@@ -1,5 +1,6 @@
 import json
 import logging
+from asyncio import gather
 from threading import Lock
 from typing import List, Dict, Any, Set, Tuple, cast, Optional, TYPE_CHECKING
 
@@ -69,7 +70,9 @@ class OSDService(CephService):
             return ret_msg
 
         async def all_hosts() -> List[Optional[str]]:
-            return [await create_from_spec_one(h, ds) for h, ds in self.prepare_drivegroup(drive_group)]
+            futures = [create_from_spec_one(h, ds)
+                       for h, ds in self.prepare_drivegroup(drive_group)]
+            return await gather(*futures)
 
         ret = self.mgr.wait_async(all_hosts())
         return ", ".join(filter(None, ret))