From bb40e723bacc49b85868ad2fd861cac42b906127 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Mon, 4 Aug 2025 15:32:49 -0300 Subject: [PATCH] SIENTIAPDE-1174 Update BaseActivity initialization in manager classes to enable error counter metric - Modified the initialization of DataManager, IngestorManager, OpcManager, and ResourceManager to include 'set_error_counter=True' for enhanced error tracking. --- ingestor/managers/data_manager.py | 2 +- ingestor/managers/ingestor_manager.py | 2 +- ingestor/managers/opc_manager.py | 2 +- ingestor/managers/resource_manager.py | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/ingestor/managers/data_manager.py b/ingestor/managers/data_manager.py index 4984682..5d58c51 100644 --- a/ingestor/managers/data_manager.py +++ b/ingestor/managers/data_manager.py @@ -97,7 +97,7 @@ class DataManager(BaseActivity): BaseActivity.__init__(self, logger=logger, notification_handler=notification_handler, - set_error_counter_metric=False) + set_error_counter=True) def shutdown(self): """Closes the Kafka producer connection.""" diff --git a/ingestor/managers/ingestor_manager.py b/ingestor/managers/ingestor_manager.py index 879531c..a9303da 100644 --- a/ingestor/managers/ingestor_manager.py +++ b/ingestor/managers/ingestor_manager.py @@ -57,7 +57,7 @@ class IngestorManager(BaseActivity): BaseActivity.__init__(self, logger=logger, notification_handler=notification_handler, - set_error_counter_metric=False) + set_error_counter=True) def initialize_opc_from_config(self, server_config: dict) -> OpcManager | None: """ diff --git a/ingestor/managers/opc_manager.py b/ingestor/managers/opc_manager.py index 3e32e2e..332a2ca 100644 --- a/ingestor/managers/opc_manager.py +++ b/ingestor/managers/opc_manager.py @@ -36,7 +36,7 @@ class OpcManager(BaseActivity): BaseActivity.__init__(self, logger=logger, notification_handler=notification_handler, - set_error_counter_metric=False) + set_error_counter=True) def __str__(self): return f"OpcManager(name={self.name}, url={self.url}, server_uri={self.server_uri})\n" \ diff --git a/ingestor/managers/resource_manager.py b/ingestor/managers/resource_manager.py index bee722d..de2d3b2 100644 --- a/ingestor/managers/resource_manager.py +++ b/ingestor/managers/resource_manager.py @@ -45,7 +45,7 @@ class ResourceManager(BaseActivity): BaseActivity.__init__(self, logger=logger, notification_handler=notification_handler, - set_error_counter_metric=False) + set_error_counter=True) def _execute_redis_op(self, operation_name: str, func, *args, **kwargs): """Wrapper to execute Redis operations and record metrics."""