fix: changes to time handler

Author: raphael-goetz

crates/taurus-core/src/runtime/engine.rs

@@ -414,7 +414,7 @@ mod tests {
         _ctx: &mut ValueStore,
         _run: &mut ThunkRunner<'_>,
     ) -> Signal {
-        std::thread::sleep(Duration::from_millis(2));
+        std::thread::sleep(Duration::from_micros(2_000));
         Signal::Success(null_value())
     }
 

crates/taurus-core/src/runtime/execution/value_store.rs

@@ -9,7 +9,6 @@ use tucana::shared::{
 };
 
 use crate::runtime::execution::trace::{StoreInputSlotEntry, StoreResultEntry, StoreSnapshot};
-use crate::time::now_unix_micros;
 use crate::types::errors::runtime_error::RuntimeError;
 
 #[derive(Clone)]
@@ -147,20 +146,6 @@ impl ValueStore {
         self.flow_input = value;
     }
 
-    pub fn insert_success(&mut self, id: i64, value: Value) {
-        self.insert_success_with_parameters(id, value, Vec::new());
-    }
-
-    pub fn insert_success_with_parameters(
-        &mut self,
-        id: i64,
-        value: Value,
-        parameter_results: Vec<NodeParameterNodeExecutionResult>,
-    ) {
-        let ts = now_unix_micros();
-        self.insert_success_with_timing(id, value, parameter_results, ts, ts);
-    }
-
     pub fn insert_success_with_timing(
         &mut self,
         id: i64,
@@ -181,20 +166,6 @@ impl ValueStore {
         );
     }
 
-    pub fn insert_error(&mut self, id: i64, runtime_error: RuntimeError) {
-        self.insert_error_with_parameters(id, runtime_error, Vec::new());
-    }
-
-    pub fn insert_error_with_parameters(
-        &mut self,
-        id: i64,
-        runtime_error: RuntimeError,
-        parameter_results: Vec<NodeParameterNodeExecutionResult>,
-    ) {
-        let ts = now_unix_micros();
-        self.insert_error_with_timing(id, runtime_error, parameter_results, ts, ts);
-    }
-
     pub fn insert_error_with_timing(
         &mut self,
         id: i64,

crates/taurus-core/src/time.rs

@@ -8,10 +8,3 @@ pub fn now_unix_micros() -> i64 {
         .map(|it| it.as_micros() as i64)
         .unwrap_or(0)
 }
-
-pub fn now_unix_ms() -> i64 {
-    SystemTime::now()
-        .duration_since(UNIX_EPOCH)
-        .map(|it| it.as_millis() as i64)
-        .unwrap_or(0)
-}

crates/taurus-core/src/types/errors/runtime_error.rs

@@ -15,7 +15,7 @@ use tucana::shared::{
     Error as TucanaError, NumberValue as ProtoNumberValue, Struct, Value, number_value,
 };
 
-use crate::time::now_unix_ms;
+use crate::time::now_unix_micros;
 
 /// Runtime execution failure representation.
 #[derive(Debug, Clone, PartialEq)]
@@ -26,8 +26,8 @@ pub struct RuntimeError {
     pub category: String,
     /// Human-readable diagnostic message.
     pub message: String,
-    /// Unix timestamp in milliseconds when this error object was created.
-    pub timestamp_unix_ms: u64,
+    /// Unix timestamp in microseconds when this error object was created.
+    pub timestamp_unix_micros: u64,
     /// Runtime version identifier.
     pub version: String,
     /// Dependency versions relevant to this runtime.
@@ -47,7 +47,7 @@ impl RuntimeError {
             code: code.into(),
             category: category.into(),
             message: message.into(),
-            timestamp_unix_ms: now_unix_ms() as u64,
+            timestamp_unix_micros: now_unix_micros() as u64,
             version: env!("CARGO_PKG_VERSION").to_string(),
             dependencies: HashMap::new(),
             details: HashMap::new(),
@@ -112,7 +112,7 @@ impl RuntimeError {
                         Value {
                             kind: Some(NumberValue(ProtoNumberValue {
                                 number: Some(number_value::Number::Integer(
-                                    self.timestamp_unix_ms as i64,
+                                    self.timestamp_unix_micros as i64,
                                 )),
                             })),
                         },
@@ -150,7 +150,7 @@ impl RuntimeError {
             code: self.code.clone(),
             category: self.category.clone(),
             message: self.message.clone(),
-            timestamp: self.timestamp_unix_ms as i64,
+            timestamp: self.timestamp_unix_micros as i64,
             version: self.version.clone(),
             dependencies: self.dependencies.clone(),
             details: Some(Struct {
@@ -165,7 +165,7 @@ impl RuntimeError {
             code: error.code.clone(),
             category: error.category.clone(),
             message: error.message.clone(),
-            timestamp_unix_ms: error.timestamp.max(0) as u64,
+            timestamp_unix_micros: error.timestamp.max(0) as u64,
             version: error.version.clone(),
             dependencies: error.dependencies.clone(),
             details: error