diff --git a/exponential-smoothing-predictor/src/runtime/Predictor.py b/exponential-smoothing-predictor/src/runtime/Predictor.py index 49c8a14..950c296 100755 --- a/exponential-smoothing-predictor/src/runtime/Predictor.py +++ b/exponential-smoothing-predictor/src/runtime/Predictor.py @@ -311,8 +311,9 @@ 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) - logging.info("New monitoring data arrived at topic "+address) if address == 'metric_list': application_name = body["name"]