test: investigate hanging failover test

Author: karenc-bq

.github/workflows/integration_tests.yml

@@ -18,7 +18,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: [ "3.8", "3.11" ]
+        python-version: [ "3.11" ]
         engine-version: [ "lts", "latest" ]
         environment: ["mysql"]
 

aws_advanced_python_wrapper/plugin_service.py

@@ -406,28 +406,36 @@ def set_current_connection(self, connection: Optional[Connection], host_info: Op
 
                 if is_in_transaction and WrapperProperties.ROLLBACK_ON_SWITCH.get_bool(self.props):
                     try:
+                        logger.info("Rolling back connection")
                         old_connection.rollback()
-                    except Exception:
+                    except Exception as e:
+                        logger.error(f"Failed to rollback connection: {e}")
                         # Ignore any exception.
                         pass
 
+                logger.info("notify_connection_changed")
                 old_connection_suggested_action = \
                     self._container.plugin_manager.notify_connection_changed({ConnectionEvent.CONNECTION_OBJECT_CHANGED})
 
                 if old_connection_suggested_action != OldConnectionSuggestedAction.PRESERVE and not self.driver_dialect.is_closed(old_connection):
 
                     try:
+                        logger.info("apply_pristine_session_state")
                         self.session_state_service.apply_pristine_session_state(old_connection)
-                    except Exception:
+                    except Exception as e:
+                        logger.error(f"Failed to apply pristine session state to old connection: {e}")
                         # Ignore any exception.
                         pass
 
                     try:
+                        logger.info("closing old connection")
                         old_connection.close()
                     except Exception:
+                        logger.error(f"Failed to close old connection: {e}")
                         # Ignore any exception.
                         pass
             finally:
+                logger.info("Complete connection update")
                 self.session_state_service.complete()
 
     @property