Skip to content

Commit

Permalink
origin/misc_improvements (#14)
Browse files Browse the repository at this point in the history
* 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
  • Loading branch information
atsag authored Oct 7, 2024
1 parent 18e024c commit 269791a
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion exponential-smoothing-predictor/src/exn/connector.py
Original file line number Diff line number Diff line change
Expand Up @@ -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__)


Expand Down
2 changes: 1 addition & 1 deletion exponential-smoothing-predictor/src/exn/core/consumer.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down
2 changes: 1 addition & 1 deletion exponential-smoothing-predictor/src/exn/core/context.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@


_logger = logging.getLogger(__name__)
_logger.setLevel(logging.DEBUG)
_logger.setLevel(logging.WARN)

class Context:

Expand Down
2 changes: 1 addition & 1 deletion exponential-smoothing-predictor/src/exn/core/manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
from .publisher import Publisher

_logger = logging.getLogger(__name__)
_logger.setLevel(logging.DEBUG)
_logger.setLevel(logging.WARN)


class SessionPerConsumer(object):
Expand Down
2 changes: 1 addition & 1 deletion exponential-smoothing-predictor/src/runtime/Predictor.py
Original file line number Diff line number Diff line change
Expand Up @@ -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':
Expand Down

0 comments on commit 269791a

Please sign in to comment.