aqr: Fix shutdown procedure

cephadm appears to leave open a thread lock, use os._exit to quit when we're ready. Signed-off-by: Joshua Hesketh <[email protected]>
jhesketh · Jan 18, 2022 · a1452b1 · a1452b1
1 parent 9b1798e
commit a1452b1
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/aquarium.py b/src/aquarium.py
@@ -179,8 +179,6 @@ async def run(self):
 
         await self.stop_uvicorn()
         await self.shutdown()
-        # await self.gstate.shutdown()
-        # await self.nodemgr.shutdown()
 
     async def bootstrap(self):
         logger.debug("Starting main Aquarium task.")
@@ -291,6 +289,9 @@ async def shutdown(self):
         logger.info("Stopping deployment task.")
         await self.deployment.shutdown()
 
+        logger.info("Closing KVStore")
+        await self.kvstore.close()
+
     async def start_uvicorn(self):
         logger.debug("Starting uvicorn")
         if self.gstate.config.options.ssl.use_ssl:
@@ -337,6 +338,7 @@ def main():
 
     aqr = Aquarium()
     asyncio.run(aqr.run())
+    os._exit(0)
 
 
 if __name__ == "__main__":