Call check() before querying PG connection pool

check() checks that none of the connections in the pool have gone bad and if they have replaces them

Author: aaronfriedman6

src/nypl_py_utils/classes/postgresql_client.py

@@ -73,6 +73,7 @@ def execute_query(self, query, is_write_query=False, query_params=None,
         """
         self.logger.info('Querying {} database'.format(self.db_name))
         self.logger.debug('Executing query {}'.format(query))
+        self.pool.check()
         with self.pool.connection() as conn:
             try:
                 conn.row_factory = row_factory