From dd9aebb6bc0cb0d28d4c5b1016904cb95d2f0117 Mon Sep 17 00:00:00 2001 From: Vigith Maurice Date: Wed, 19 Feb 2025 19:29:24 -0800 Subject: [PATCH] chore: fmt Signed-off-by: Vigith Maurice --- rust/serving/src/app/callback/state.rs | 2 +- rust/serving/src/app/callback/store/redisstore.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/rust/serving/src/app/callback/state.rs b/rust/serving/src/app/callback/state.rs index 420b1a9797..28bb004405 100644 --- a/rust/serving/src/app/callback/state.rs +++ b/rust/serving/src/app/callback/state.rs @@ -45,7 +45,7 @@ where /// register a new connection /// The oneshot receiver will be notified when all callbacks for this connection is received from - /// the numaflow pipeline. + /// the numaflow pipeline. pub(crate) async fn register( &mut self, id: Option, diff --git a/rust/serving/src/app/callback/store/redisstore.rs b/rust/serving/src/app/callback/store/redisstore.rs index 21545cfee3..d3f0c9087e 100644 --- a/rust/serving/src/app/callback/store/redisstore.rs +++ b/rust/serving/src/app/callback/store/redisstore.rs @@ -136,7 +136,7 @@ impl super::Store for RedisConnection { Ok(id) } None => { - // We use UUID v7 as the request id. Attempt for a maxium of 5 times to generate an + // We use UUID v7 as the request id. Attempt for a maxium of 5 times to generate an // id that doesn't currently exist in the Store. for _ in 0..5 { let id = Uuid::now_v7().to_string();