From b28b93f837b5da7332e3174bfbc3f33b26ac4bf2 Mon Sep 17 00:00:00 2001 From: Juan Lee Date: Wed, 3 Sep 2025 01:22:20 -0700 Subject: [PATCH] fix: Update subscribe methods for efm --- aws_advanced_python_wrapper/host_monitoring_plugin.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/aws_advanced_python_wrapper/host_monitoring_plugin.py b/aws_advanced_python_wrapper/host_monitoring_plugin.py index faa76570..2159e43e 100644 --- a/aws_advanced_python_wrapper/host_monitoring_plugin.py +++ b/aws_advanced_python_wrapper/host_monitoring_plugin.py @@ -58,7 +58,7 @@ def get_instance(self, plugin_service: PluginService, props: Properties) -> Plug class HostMonitoringPlugin(Plugin, CanReleaseResources): - _SUBSCRIBED_METHODS: Set[str] = {"*"} + _SUBSCRIBED_METHODS: Set[str] = {"connect", "notify_host_list_changed", "notify_connection_changed"} def __init__(self, plugin_service, props): dialect: DriverDialect = plugin_service.driver_dialect @@ -73,6 +73,7 @@ def __init__(self, plugin_service, props): self._rds_utils: RdsUtils = RdsUtils() self._monitor_service: MonitorService = MonitorService(plugin_service) self._lock: Lock = Lock() + HostMonitoringPlugin._SUBSCRIBED_METHODS.update(self._plugin_service.network_bound_methods) @property def subscribed_methods(self) -> Set[str]: