ISSUE #346

* Fix bug related with a blocking status related with pool dependencies.

Author: Sergio García Prado

packages/core/minos-microservice-common/minos/common/pools.py

@@ -8,6 +8,7 @@
     ABC,
 )
 from asyncio import (
+    gather,
     sleep,
 )
 from typing import (
@@ -59,10 +60,15 @@ def _from_config(cls, config: Config, **kwargs) -> PoolFactory:
         return cls(config, **kwargs)
 
     async def _destroy(self) -> None:
-        for pool in self._pools.values():
-            await pool.destroy()
+        await self._destroy_pools()
         await super()._destroy()
 
+    async def _destroy_pools(self):
+        logger.debug("Destroying pools...")
+        futures = (pool.destroy() for pool in self._pools.values())
+        await gather(*futures)
+        logger.debug("Destroyed pools!")
+
     def get_pool(self, type_: str, key: Optional[str] = None, **kwargs) -> Pool:
         """Get a pool from the factory.
 
@@ -145,6 +151,7 @@ async def _destroy(self) -> None:
             logger.info("Waiting for instances releasing...")
             while len(self._used):
                 await sleep(0.1)
+            logger.info("Released instances!")
 
         await self.close()