Commit cce72486 authored by Anna Warno's avatar Anna Warno
Browse files

time loop corected

parent c0a6c402
......@@ -25,6 +25,10 @@ def main(predicted_metrics, prediction_horizon):
dataset_preprocessor = CSVData(APP_NAME)
dataset_preprocessor.prepare_csv()
for metric in predicted_metrics:
retrain_msg = train(metric, prediction_horizon)
start_conn.send_to_topic(TOPIC_NAME, retrain_msg)
@tl.job(interval=timedelta(seconds=60 * RETRAIN_CYCLE))
def retrain_model():
logging.debug("TRAINING")
......
......@@ -25,6 +25,10 @@ def main(predicted_metrics, prediction_horizon):
dataset_preprocessor = CSVData(APP_NAME)
dataset_preprocessor.prepare_csv()
for metric in predicted_metrics:
retrain_msg = train(metric, prediction_horizon)
start_conn.send_to_topic(TOPIC_NAME, retrain_msg)
@tl.job(interval=timedelta(seconds=60 * RETRAIN_CYCLE))
def retrain_model():
logging.debug("TRAINING")
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment