predictions corrected

deployment/nbeats/main.py

@@ -114,11 +114,11 @@ def main():
     )
 
     # msg1 = Msg()
-    # msg1.body = '[{"metric": "memory", "level": 3, "publish_rate": 10000}]'
+    # msg1.body = '[{"metric": "memory", "level": 3, "publish_rate": 30000}]'
     # msg2 = Msg()
     # msg2.body = (
     #     "{"
-    #     + f'"metrics": ["memory"],"timestamp": {int(time.time())}, "epoch_start": {int(time.time()) + 30}, "number_of_forward_predictions": 8,"prediction_horizon": 20'
+    #     + f'"metrics": ["memory"],"timestamp": {int(time.time())}, "epoch_start": {int(time.time()) + 30}, "number_of_forward_predictions": 8,"prediction_horizon": 30'
     #     + "}"
     # )
 

deployment/nbeats/predict.py

@@ -126,7 +126,7 @@ def main():
                 prediction_msgs, prediction = predict(
                     metric,
                     prediction_length,
-                    extra_data=predictions,
+                    extra_data=None,
                     m=i + 1,
                     prediction_hor=prediction_horizon,
                     timestamp=time_0 + (i + 1) * (prediction_horizon // 1000),
@@ -136,10 +136,7 @@ def main():
                     print(
                         f"time_0 difference seconds  {start_time + (i + 1) * prediction_horizon // 1000  - int(time.time())}"
                     )
-                # if predictions is not None:
-                #     predictions = pd.concat(
-                #         [predictions, prediction], ignore_index=True
-                #     )
+
                 else:
                     predictions = prediction
 

deployment/tft/predict.py

@@ -126,7 +126,7 @@ def main():
                 prediction_msgs, prediction = predict(
                     metric,
                     prediction_length,
-                    extra_data=predictions,
+                    extra_data=None,
                     m=i + 1,
                     prediction_hor=prediction_horizon,
                     timestamp=time_0 + (i + 1) * (prediction_horizon // 1000),