Merge pull request #657 from bugout-dev/add-pre-ping

Add pool pre ping parameter.

db/moonstreamdb/db.py

@@ -39,11 +39,14 @@ except:
     )
 
 
-def create_moonstream_engine(url: str, pool_size: int, statement_timeout: int):
+def create_moonstream_engine(
+    url: str, pool_size: int, statement_timeout: int, pool_pre_ping: bool = False
+):
     # Pooling: https://docs.sqlalchemy.org/en/14/core/pooling.html#sqlalchemy.pool.QueuePool
     # Statement timeout: https://stackoverflow.com/a/44936982
     return create_engine(
         url=url,
+        pool_pre_ping=pool_pre_ping,
         pool_size=pool_size,
         connect_args={"options": f"-c statement_timeout={statement_timeout}"},
     )

db/moonstreamdb/version.py

@@ -2,4 +2,4 @@
 Moonstream database version.
 """
 
-MOONSTREAMDB_VERSION = "0.3.1"
+MOONSTREAMDB_VERSION = "0.3.2"