no pool recycle

services/metadata_service/server.py

@@ -15,6 +15,9 @@
 from services.data.postgres_async_db import AsyncPostgresDB
 from services.utils import DBConfiguration
 
+import logging
+import time
+
 
 def app(loop=None, db_conf: DBConfiguration = None, middlewares=None):
 
@@ -33,19 +36,42 @@ def app(loop=None, db_conf: DBConfiguration = None, middlewares=None):
 
 
 def main():
-    loop = asyncio.get_event_loop()
-    the_app = app(loop, DBConfiguration())
-    handler = the_app.make_handler()
-    port = os.environ.get("MF_METADATA_PORT", 8080)
-    host = str(os.environ.get("MF_METADATA_HOST", "0.0.0.0"))
-    f = loop.create_server(handler, host, port)
-
-    srv = loop.run_until_complete(f)
-    print("serving on", srv.sockets[0].getsockname())
-    try:
-        loop.run_forever()
-    except KeyboardInterrupt:
-        pass
+    is_iam = os.environ.get("MF_METADATA_USE_IAM", "False") == "True"
+    if not is_iam:
+        loop = asyncio.get_event_loop()
+        the_app = app(loop, DBConfiguration())
+        handler = the_app.make_handler()
+        port = os.environ.get("MF_METADATA_PORT", 8080)
+        host = str(os.environ.get("MF_METADATA_HOST", "0.0.0.0"))
+        f = loop.create_server(handler, host, port)
+
+        srv = loop.run_until_complete(f)
+        print("serving on", srv.sockets[0].getsockname())
+        try:
+            loop.run_forever()
+        except KeyboardInterrupt:
+            pass
+    else:
+        loop = asyncio.get_event_loop()
+        port = os.environ.get("MF_METADATA_PORT", 8080)
+        host = str(os.environ.get("MF_METADATA_HOST", "0.0.0.0"))
+
+        while True:
+            logging.info("IAM LOOP STARTING")
+            the_app = app(loop, DBConfiguration())
+            handler = the_app.make_handler()
+            f = loop.create_server(handler, host, port)
+
+            srv = loop.run_until_complete(f)
+            print("serving on", srv.sockets[0].getsockname())
+            try:
+                loop.run_forever()
+                logging.info("IAM LOOPING")
+                time.sleep(900)
+                loop.stop() 
+                logging.info("IAM LOOP STOPPED")
+            except KeyboardInterrupt:
+                pass
 
 
 if __name__ == "__main__":

services/utils/__init__.py

@@ -274,6 +274,7 @@ def connection_string_url(self):
 
     @property
     def dsn(self):
+        logging.info("Asking for Dsn")
         if self._dsn is None:
             ssl_mode = self._ssl_mode
             sslcert = self._ssl_cert_path