chore: log monitoring properties

Author: karenc-bq

aws_advanced_python_wrapper/utils/properties.py

@@ -13,12 +13,15 @@
 #  limitations under the License.
 
 import copy
+import logging
 from typing import Any, Dict, Optional
 from urllib.parse import unquote
 
 from aws_advanced_python_wrapper.errors import AwsWrapperError
 from aws_advanced_python_wrapper.utils.messages import Messages
 
+logger = logging.getLogger(__name__)
+
 
 class Properties(Dict[str, Any]):
     def put_if_absent(self, key: str, value: Any):
@@ -621,4 +624,6 @@ def create_monitoring_properties(props: Properties) -> Properties:
             if property_key.startswith(PropertiesUtils._MONITORING_PROPERTY_PREFIX):
                 monitoring_properties[property_key[len(PropertiesUtils._MONITORING_PROPERTY_PREFIX):]] = \
                     monitoring_properties.pop(property_key)
+        
+        logger.info(f"Monitoring properties created: {PropertiesUtils.mask_properties(monitoring_properties)}")
         return monitoring_properties

tests/integration/container/test_aurora_failover.py

@@ -66,7 +66,7 @@ def aurora_utility(self):
     def props(self):
         p: Properties = Properties({
             "plugins": "failover",
-            "socket_timeout": 30,
+            "socket_timeout": 10,
             "connect_timeout": 10,
             "monitoring-connect_timeout": 5,
             "monitoring-socket_timeout": 5,
@@ -329,28 +329,3 @@ def test_writer_failover_in_idle_connections(
         # Ensure that all idle connections are closed.
         for idle_connection in idle_connections:
             assert idle_connection.is_closed is True
-
-    @enable_on_features([TestEnvironmentFeatures.NETWORK_OUTAGES_ENABLED])
-    def test_failover__socket_timeout(
-            self,
-            test_driver: TestDriver,
-            test_environment: TestEnvironment,
-            proxied_props,
-            conn_utils,
-            aurora_utility):
-        target_driver_connect = DriverHelper.get_connect_func(test_driver)
-        reader: TestInstanceInfo = test_environment.get_proxy_instances()[1]
-        writer_id: str = test_environment.get_proxy_writer().get_instance_id()
-
-        WrapperProperties.PLUGINS.set(proxied_props, "failover")
-        WrapperProperties.SOCKET_TIMEOUT_SEC.set(proxied_props, 3)
-        with AwsWrapperConnection.connect(
-                target_driver_connect,
-                **conn_utils.get_proxy_connect_params(reader.get_host()),
-                **proxied_props) as aws_conn:
-            ProxyHelper.disable_connectivity(reader.get_instance_id())
-            aurora_utility.assert_first_query_throws(aws_conn, FailoverSuccessError)
-
-            current_connection_id = aurora_utility.query_instance_id(aws_conn)
-            assert writer_id == current_connection_id
-            assert aurora_utility.is_db_instance_writer(current_connection_id) is True

tests/integration/container/test_read_write_splitting.py

@@ -244,9 +244,6 @@ def test_set_read_only_true__all_readers_down(
         target_driver_connect = DriverHelper.get_connect_func(test_driver)
         connect_params = conn_utils.get_proxy_connect_params()
 
-        # To prevent endless waiting while executing SQL queries
-        WrapperProperties.SOCKET_TIMEOUT_SEC.set(connect_params, 10)
-
         with AwsWrapperConnection.connect(target_driver_connect, **connect_params, **proxied_props) as conn:
             writer_id = rds_utils.query_instance_id(conn)