send non-trivial ts in init phase

SENERGY-Platform · May 24, 2024 · e91c31a · e91c31a
1 parent 5a8d1b4
commit e91c31a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/main.py b/main.py
@@ -70,7 +70,7 @@ def init(self, *args, **kwargs):
         self.init_phase_handler = InitPhase(self.data_path, self.init_phase_duration, self.first_data_time, self.produce)
         value = {
             "window_open": False,
-            "timestamp": ""
+            "timestamp": timestamp_to_str(pd.Timestamp.now())
         }
         self.init_phase_handler.send_first_init_msg(value)    
 
@@ -108,7 +108,7 @@ def run(self, data, selector = None, device_id=None):
 
         init_value = {
             "window_open": False,
-            "timestamp": ""
+            "timestamp": timestamp_to_str(current_timestamp)
         }
         operator_is_init = self.init_phase_handler.operator_is_in_init_phase(current_timestamp)
         if operator_is_init: