Better handling of start_forecasting message
Compare changes
@@ -171,6 +171,7 @@ def calculate_and_publish_predictions(prediction_horizon,maximum_time_required_f
@@ -269,7 +270,7 @@ class Listener(messaging.listener.MorphemicListener):
State.next_prediction_time = update_prediction_time(State.epoch_start,prediction_horizon,State.prediction_processing_time_safety_margin_seconds) # State.next_prediction_time was assigned the value of State.epoch_start here, but this re-initializes targeted prediction times after each start_forecasting message, which is not desired necessarily