time units correected

deployment/nbeats/predict.py

@@ -106,7 +106,7 @@ def main():
             for i in range(number_of_forward_predictions[metric]):
                 prediction_msgs, prediction = predict(
                     metric,
-                    prediction_cycle // msg["publish_rate"],
+                    (prediction_cycle * 1000) // msg["publish_rate"],
                     extra_data=predictions,
                     m=i + 1,
                     prediction_hor=prediction_horizon,

deployment/tft/predict.py

@@ -106,7 +106,7 @@ def main():
             for i in range(number_of_forward_predictions[metric]):
                 prediction_msgs, prediction = predict(
                     metric,
-                    prediction_cycle // msg["publish_rate"],
+                    (prediction_cycle * 1000) // msg["publish_rate"],
                     extra_data=predictions,
                     m=i + 1,
                     prediction_hor=prediction_horizon,