chore: add logs

Author: karenc-bq

aws_advanced_python_wrapper/failover_plugin.py

@@ -289,11 +289,13 @@ def _failover_reader(self, failed_host: Optional[HostInfo]):
             context.set_success(True)
             context.set_exception(fse)
             self._failover_reader_success_counter.inc()
+            logger.info("FailoverSuccessError thrown", exc_info=fse)
             raise fse
         except Exception as ex:
             context.set_success(False)
             context.set_exception(ex)
             self._failover_reader_failed_counter.inc()
+            logger.info("encountered error during reader failover", exc_info=ex)
             raise ex
         finally:
             context.close_context()

tests/integration/container/test_read_write_splitting.py

@@ -543,9 +543,9 @@ def test_pooled_connection__failover_failed(
         provider = SqlAlchemyPooledConnectionProvider(lambda _, __: {"pool_size": 1}, None, lambda host_info, props: writer_host in host_info.host)
         ConnectionProviderManager.set_connection_provider(provider)
 
-        WrapperProperties.FAILOVER_TIMEOUT_SEC.set(proxied_failover_props, "1")
+        WrapperProperties.FAILOVER_TIMEOUT_SEC.set(proxied_failover_props, "3")
         WrapperProperties.FAILURE_DETECTION_TIME_MS.set(proxied_failover_props, "1000")
-        WrapperProperties.FAILURE_DETECTION_COUNT.set(proxied_failover_props, "1")
+        WrapperProperties.FAILURE_DETECTION_COUNT.set(proxied_failover_props, "3")
         WrapperProperties.PLUGINS.set(proxied_failover_props, plugins)
 
         target_driver_connect = DriverHelper.get_connect_func(test_driver)