diff --git a/laborious/activities/gates.py b/laborious/activities/gates.py index f859609..39199d9 100644 --- a/laborious/activities/gates.py +++ b/laborious/activities/gates.py @@ -64,9 +64,6 @@ class Gates(BaseActivity): tuple[str | None, int, str]: (policy, confidence, comments) based in priority list and filter configuration and functions. """ - - self.debug(f"Input data: {input_data}") - metadata = input_data['metadata'] self.debug("Performing input gate...", metadata) diff --git a/laborious/utils/repository/opc_repository.py b/laborious/utils/repository/opc_repository.py index a881b6e..3ae6c2a 100644 --- a/laborious/utils/repository/opc_repository.py +++ b/laborious/utils/repository/opc_repository.py @@ -114,6 +114,7 @@ class OpcRepository(): Returns: bool: True if the connection was successful, False otherwise. """ + try: self.last_reconnection_time = datetime.now() self.client.connect() @@ -136,9 +137,12 @@ class OpcRepository(): """ if self.client is None: return - self.client.disconnect() + try: + self.client.disconnect() + self.logger.info('Disconnected from OPC server') + except Exception as e: + self.logger.error(f"Failed to disconnect from OPC server: {e}") self.client = None - self.logger.info('Disconnected from OPC server') def __del__(self): """ @@ -182,11 +186,12 @@ class OpcRepository(): self.logger.error( f"OPC server {self.id} is not connected") - if (datetime.now() - self.last_reconnection_time).total_seconds( + if self.last_reconnection_time is None or (datetime.now() - self.last_reconnection_time).total_seconds( ) > self.reconnection_interval: + self.disconnect() self.logger.error( f"Trying to reconnect to OPC server {self.id}...") - return self.try_connect() + return self.connect() return False