gitea_admin/sientia-dataops-opc-ingestor
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SIENTIAPDE-1174

Browse Source 
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.
This commit is contained in:
vitor-aignosi
2025-08-04 15:32:49 -03:00
parent e8f85b64e9
commit bb40e723ba
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ingestor/managers/data_manager.py
View File

@@ -97,7 +97,7 @@ class DataManager(BaseActivity):
BaseActivity.__init__(self, logger=logger, BaseActivity.__init__(self, logger=logger,
notification_handler=notification_handler, notification_handler=notification_handler,
set_error_counter_metric=False) set_error_counter=True)
def shutdown(self): def shutdown(self):
"""Closes the Kafka producer connection.""" """Closes the Kafka producer connection."""

2
ingestor/managers/ingestor_manager.py
View File

@@ -57,7 +57,7 @@ class IngestorManager(BaseActivity):
BaseActivity.__init__(self, logger=logger, BaseActivity.__init__(self, logger=logger,
notification_handler=notification_handler, notification_handler=notification_handler,
set_error_counter_metric=False) set_error_counter=True)
def initialize_opc_from_config(self, server_config: dict) -> OpcManager | None: def initialize_opc_from_config(self, server_config: dict) -> OpcManager | None:
""" """

2
ingestor/managers/opc_manager.py
View File

@@ -36,7 +36,7 @@ class OpcManager(BaseActivity):
BaseActivity.__init__(self, logger=logger, BaseActivity.__init__(self, logger=logger,
notification_handler=notification_handler, notification_handler=notification_handler,
set_error_counter_metric=False) set_error_counter=True)
def __str__(self): def __str__(self):
return f"OpcManager(name={self.name}, url={self.url}, server_uri={self.server_uri})\n" \ return f"OpcManager(name={self.name}, url={self.url}, server_uri={self.server_uri})\n" \

2
ingestor/managers/resource_manager.py
View File

@@ -45,7 +45,7 @@ class ResourceManager(BaseActivity):
BaseActivity.__init__(self, logger=logger, BaseActivity.__init__(self, logger=logger,
notification_handler=notification_handler, notification_handler=notification_handler,
set_error_counter_metric=False) set_error_counter=True)
def _execute_redis_op(self, operation_name: str, func, *args, **kwargs): def _execute_redis_op(self, operation_name: str, func, *args, **kwargs):
"""Wrapper to execute Redis operations and record metrics.""" """Wrapper to execute Redis operations and record metrics."""