Preventing panic because of clock skew (meta-pytorch#1448)

jayasi · meta-codesync[bot] · commit 0c0b420c4e4c · 2025-10-07T12:34:37.000-07:00
Summary: Pull Request resolved: meta-pytorch#1448 As titled. Reviewed By: vidhyav Differential Revision: D84067046 fbshipit-source-id: c8784ec14b535bf6b05424e8b7bf9e916e97d12a
diff --git a/hyperactor/src/mailbox/headers.rs b/hyperactor/src/mailbox/headers.rs
@@ -56,6 +56,6 @@ pub fn log_message_latency_if_sampling(headers: &Attrs, actor_id: String) {
         return;
     };
     let now = RealClock.system_time_now();
-    let latency = now.duration_since(*send_timestamp).unwrap();
+    let latency = now.duration_since(*send_timestamp).unwrap_or_default();
     MESSAGE_LATENCY_MICROS.record(latency.as_micros() as f64, metric_pairs);
 }

Original file line number	Diff line number	Diff line change
`@@ -56,6 +56,6 @@ pub fn log_message_latency_if_sampling(headers: &Attrs, actor_id: String) {`
`56`	`56`	`return;`
`57`	`57`	`};`
`58`	`58`	`let now = RealClock.system_time_now();`
`59`		`- let latency = now.duration_since(*send_timestamp).unwrap();`
	`59`	`+ let latency = now.duration_since(*send_timestamp).unwrap_or_default();`
`60`	`60`	`MESSAGE_LATENCY_MICROS.record(latency.as_micros() as f64, metric_pairs);`
`61`	`61`	`}`