diff --git a/src/dls_normsql/aiomysql.py b/src/dls_normsql/aiomysql.py index 31c6a90..3f4d7de 100644 --- a/src/dls_normsql/aiomysql.py +++ b/src/dls_normsql/aiomysql.py @@ -215,9 +215,15 @@ async def disconnect(self): if self.__connection is not None: # Commit final transaction if not currently autocommitting. - if not self.__connection.get_autocommit(): - logger.debug(f"[DISSHU] {callsign(self)} committing final transaction") + try: await self.__connection.commit() + logger.debug( + f"[DISSHU] {callsign(self)} successfully committed final transaction" + ) + except Exception as exception: + logger.warning( + callsign(self, explain(exception, "committing final transaction")) + ) logger.debug(f"[DISSHU] {callsign(self)} closing connection to server") self.__connection.close() self.__connection = None