From 269791a6f5ffb1a8f7832339ca6b422a6e4fe76e Mon Sep 17 00:00:00 2001
From: atsag <andreastsagkaropoulos@hotmail.com>
Date: Mon, 7 Oct 2024 18:18:54 +0300
Subject: [PATCH] origin/misc_improvements (#14)

* Miscellaneous improvements

Added required dependencies in the setup script
Improved logging during dataset creation
Added README.md file

Change-Id: I67e98938f3660656d2ced916f258dfe5d475ecd3

* Readme file location correction

Corrected the location of the README.md file

Change-Id: I89b86b7471123d653592cd98f513ff25181d2520

* Environment variable correction

Added default value for an environmental variable

Change-Id: I81ca8f427c78aaec62d3eef9bad47d685e2a84ba

* Small configuration file improvements

* Corrected the publishing of forecasts for a particular application

* Retrieve the appropriate publisher to publish predictions, using the application name

* Fix the check for metric_list message version

* Necessary Improvements to allow multi-application support

Fixed the function call procedure for individual attribute predictions

Fixed the handling of upper/lower bounds of individual attributes in prediction sanitization

* Miscellaneous improvements

Improved the logging of the forecaster

Fixed the handling of upper/lower bounds of individual attributes in prediction sanitization

* Corrections to the logging level
---
 exponential-smoothing-predictor/src/exn/connector.py     | 2 +-
 exponential-smoothing-predictor/src/exn/core/consumer.py | 2 +-
 exponential-smoothing-predictor/src/exn/core/context.py  | 2 +-
 exponential-smoothing-predictor/src/exn/core/manager.py  | 2 +-
 exponential-smoothing-predictor/src/runtime/Predictor.py | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/exponential-smoothing-predictor/src/exn/connector.py b/exponential-smoothing-predictor/src/exn/connector.py
index 22775f3..7a2601c 100755
--- a/exponential-smoothing-predictor/src/exn/connector.py
+++ b/exponential-smoothing-predictor/src/exn/connector.py
@@ -9,7 +9,7 @@
 from .settings import base
 from .handler import connector_handler
 
-logging.basicConfig(level=logging.DEBUG, format='%(asctime)s - %(levelname)s - %(message)s')
+logging.basicConfig(level=logging.WARN, format='%(asctime)s - %(levelname)s - %(message)s')
 _logger = logging.getLogger(__name__)
 
 
diff --git a/exponential-smoothing-predictor/src/exn/core/consumer.py b/exponential-smoothing-predictor/src/exn/core/consumer.py
index a92a1c2..7422409 100755
--- a/exponential-smoothing-predictor/src/exn/core/consumer.py
+++ b/exponential-smoothing-predictor/src/exn/core/consumer.py
@@ -8,7 +8,7 @@
 from proton.handlers import MessagingHandler
 
 _logger = logging.getLogger(__name__)
-_logger.setLevel(level=logging.DEBUG)
+_logger.setLevel(level=logging.WARN)
 
 
 class Consumer(link.Link, MessagingHandler):
diff --git a/exponential-smoothing-predictor/src/exn/core/context.py b/exponential-smoothing-predictor/src/exn/core/context.py
index db5cde6..fd668a2 100755
--- a/exponential-smoothing-predictor/src/exn/core/context.py
+++ b/exponential-smoothing-predictor/src/exn/core/context.py
@@ -7,7 +7,7 @@
 
 
 _logger = logging.getLogger(__name__)
-_logger.setLevel(logging.DEBUG)
+_logger.setLevel(logging.WARN)
 
 class Context:
 
diff --git a/exponential-smoothing-predictor/src/exn/core/manager.py b/exponential-smoothing-predictor/src/exn/core/manager.py
index dd4025e..9319ad0 100755
--- a/exponential-smoothing-predictor/src/exn/core/manager.py
+++ b/exponential-smoothing-predictor/src/exn/core/manager.py
@@ -9,7 +9,7 @@
 from .publisher import Publisher
 
 _logger = logging.getLogger(__name__)
-_logger.setLevel(logging.DEBUG)
+_logger.setLevel(logging.WARN)
 
 
 class SessionPerConsumer(object):
diff --git a/exponential-smoothing-predictor/src/runtime/Predictor.py b/exponential-smoothing-predictor/src/runtime/Predictor.py
index 8e57610..950c296 100755
--- a/exponential-smoothing-predictor/src/runtime/Predictor.py
+++ b/exponential-smoothing-predictor/src/runtime/Predictor.py
@@ -311,7 +311,7 @@ def on_message(self, key, address, body, context, **kwargs):
         address = address.replace("topic://"+EsPredictorState.GENERAL_TOPIC_PREFIX,"")
         if (address).startswith(EsPredictorState.MONITORING_DATA_PREFIX):
             address = address.replace(EsPredictorState.MONITORING_DATA_PREFIX, "", 1)
-            
+        
             logging.debug("New monitoring data arrived at topic "+address)
 
             if address == 'metric_list':