fix: logging for insufficient data

Signed-off-by: s0nicboOm <[email protected]>
numaproj · Nov 16, 2023 · d78c2ed · d78c2ed
1 parent 46cdfcd
commit d78c2ed
Show file tree

Hide file tree

Showing 3 changed files with 1,182 additions and 1,034 deletions.
diff --git a/numalogic/udfs/tools.py b/numalogic/udfs/tools.py
@@ -250,18 +250,21 @@ def ack_read(
             metadata.msg_train_records,
         )
         # If insufficient data: retry after (min_train_records-train_records) * data_granularity
+        _curr_time = time.time()
         if (
             _msg_train_records
             and _msg_read_ts
-            and time.time() - float(_msg_read_ts)
+            and _curr_time - float(_msg_read_ts)
             < (min_train_records - int(_msg_train_records)) * data_freq
         ):
             _LOGGER.info(
                 "%s - There was insufficient data for the key in the past: %s. Retrying fetching"
                 " and training after %s secs",
                 uuid,
                 key,
-                (min_train_records - int(_msg_train_records)) * data_freq,
+                _curr_time
+                - float(_msg_read_ts)
+                - ((min_train_records - int(_msg_train_records)) * data_freq),
             )
 
             return False