diff --git a/SAS/ResourceAssignment/ResourceAssignmentDatabase/radb.py b/SAS/ResourceAssignment/ResourceAssignmentDatabase/radb.py index 14f3e7599d3da19583db355cce1abcb99254b214..d799c0f3d866bb7a47a638c46ead738c5e1de034 100644 --- a/SAS/ResourceAssignment/ResourceAssignmentDatabase/radb.py +++ b/SAS/ResourceAssignment/ResourceAssignmentDatabase/radb.py @@ -71,13 +71,16 @@ class RADatabase: def _executeQuery(self, query, qargs=None, fetch=_FETCH_NONE): ''' Execute the query and reconnect upon OperationalError ''' - if self.log_queries: - logger.info('executing query: %s' % self._queryAsSingleLine(query, qargs)) - # Allow for 5 connection retries for i in range(5): try: + start = datetime.utcnow() self.cursor.execute(query, qargs) + if self.log_queries: + elapsed = datetime.utcnow() - start + logger.info('executed query in %s yielding %s rows: %s', elapsed, + self.cursor.rowcount, + self._queryAsSingleLine(query, qargs)) break except (psycopg2.OperationalError, AttributeError) as e: if isinstance(e, psycopg2.OperationalError):