timestamp fix

frey-perez · frey-perez · commit cf983534d28d · 2025-05-09T15:29:37.000-04:00
diff --git a/src/wristpy/core/orchestrator.py b/src/wristpy/core/orchestrator.py
@@ -351,6 +351,7 @@ def _run_file(
         temperature=watch_data.temperature,
         non_wear_algorithms=nonwear_algorithm,
     )
+
     nonwear_epoch = nonwear_utils.nonwear_array_cleanup(
         nonwear_array=nonwear_array,
         reference_measurement=activity_measurement,
diff --git a/src/wristpy/processing/mims.py b/src/wristpy/processing/mims.py
@@ -679,6 +679,8 @@ def aggregate_mims(
         },
     )
 
+    result = result.with_columns(pl.col("time").dt.truncate(f"{int(epoch)}s"))
+
     aggregated_measure = models.Measurement(
         measurements=result.select(["x", "y", "z"]).to_numpy(),
         time=result["time"].cast(pl.Datetime("ns")),

Original file line number	Diff line number	Diff line change
`@@ -351,6 +351,7 @@ def _run_file(`
`351`	`351`	`temperature=watch_data.temperature,`
`352`	`352`	`non_wear_algorithms=nonwear_algorithm,`
`353`	`353`	`)`
	`354`	`+`
`354`	`355`	`nonwear_epoch = nonwear_utils.nonwear_array_cleanup(`
`355`	`356`	`nonwear_array=nonwear_array,`
`356`	`357`	`reference_measurement=activity_measurement,`
Original file line number	Diff line number	Diff line change
`@@ -679,6 +679,8 @@ def aggregate_mims(`
`679`	`679`	`},`
`680`	`680`	`)`
`681`	`681`
	`682`	`+ result = result.with_columns(pl.col("time").dt.truncate(f"{int(epoch)}s"))`
	`683`	`+`
`682`	`684`	`aggregated_measure = models.Measurement(`
`683`	`685`	`measurements=result.select(["x", "y", "z"]).to_numpy(),`
`684`	`686`	`time=result["time"].cast(pl.Datetime("ns")),`