Merge pull request #155 from hagertnl/nick-issue141

Fix rounding issue in harness utilities
olcf · Jan 4, 2024 · a143092 · a143092
2 parents 13483f0 + 5eced76
commit a143092
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 13 deletions.
diff --git a/harness/libraries/a b/harness/libraries/a
diff --git a/harness/utilities/add_comment_to_influx.py b/harness/utilities/add_comment_to_influx.py
@@ -156,7 +156,7 @@ def post_update_to_influx(d):
             raise ValueError(e)
     # Assume it's in UTC right now, convert to EST
 
-    log_ns = int(datetime.datetime.timestamp(log_time) * 1000 * 1000) * 1000
+    log_ns = round(datetime.datetime.timestamp(log_time) * 1000 * 1000) * 1000
 
     tagline = ','.join([f"{fld}={d[fld]}" for fld in tags])
     fieldline = ','.join([f"{fld}=\"{d[fld]}\"" for fld in fields])

diff --git a/harness/utilities/change_machine_in_influx.py b/harness/utilities/change_machine_in_influx.py
@@ -149,7 +149,7 @@ def post_update_to_influx(d):
         except ValueError as e:
             raise ValueError(e)
     # microsecond timing max precision
-    log_ns = int(datetime.datetime.timestamp(log_time) * 1000 * 1000) * 1000
+    log_ns = round(datetime.datetime.timestamp(log_time) * 1000 * 1000) * 1000
 
     tagline = ','.join([f"{fld}={d[fld]}" for fld in tags])
     fieldline = ','.join([f"{fld}=\"{d[fld]}\"" for fld in fields])

diff --git a/harness/utilities/update_runs_from_slurm.py b/harness/utilities/update_runs_from_slurm.py
@@ -236,7 +236,7 @@ def post_update_to_influx(d, state_code):
     if not 'timestamp' in d.keys():
         d['timestamp'] = datetime.datetime.now().isoformat()
     log_time = datetime.strptime(d['timestamp'], "%Y-%m-%dT%H:%M:%S")
-    log_ns = int(datetime.timestamp(log_time) * 1000 * 1000) * 1000
+    log_ns = round(datetime.timestamp(log_time) * 1000 * 1000) * 1000
 
     influx_event_record_string = f"events,{','.join([f'{t}={d[t]}' for t in StatusFile.INFLUX_TAGS])} "
     quote = '"'