diff --git a/singer_sdk/connectors/sql.py b/singer_sdk/connectors/sql.py index d3cb01b91..814fdc8b2 100644 --- a/singer_sdk/connectors/sql.py +++ b/singer_sdk/connectors/sql.py @@ -327,6 +327,7 @@ def create_engine(self) -> Engine: return sa.create_engine( self.sqlalchemy_url, echo=False, + pool_pre_ping=True, json_serializer=self.serialize_json, json_deserializer=self.deserialize_json, ) @@ -337,6 +338,7 @@ def create_engine(self) -> Engine: return sa.create_engine( self.sqlalchemy_url, echo=False, + pool_pre_ping=True, ) def quote(self, name: str) -> str: