make clippy happy

Signed-off-by: Yu Juncen <yu745514916@live.com>
tikv · Mar 11, 2024 · 198136a · 198136a
1 parent c1d20f1
commit 198136a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/components/backup-stream/src/subscription_manager.rs b/components/backup-stream/src/subscription_manager.rs
@@ -559,7 +559,7 @@ where
         let start = tokio::time::Instant::now();
         debug!("Scheduing subscription."; utils::slog_region(&region), "after" => ?backoff, "handle" => ?handle);
         let scheduled = async move {
-            tokio::time::sleep_until((start + backoff).into()).await;
+            tokio::time::sleep_until(start + backoff).await;
             let handle = handle.unwrap_or_else(|| ObserveHandle::new());
             if let Err(err) = tx.send(ObserveOp::Start { region, handle }).await {
                 warn!("log backup failed to schedule start observe."; "err" => %err);

diff --git a/components/backup-stream/src/subscription_track.rs b/components/backup-stream/src/subscription_track.rs
@@ -295,7 +295,7 @@ impl SubscriptionTracer {
                         let r = s.meta.clone();
                         TRACK_REGION.dec();
                         s.stop();
-                        info!("stop listen stream from store"; "observer" => ?s, "region_id"=> %region_id);
+                        info!("Inactivating subscription."; "observer" => ?s, "region_id"=> %region_id);
 
                         *o.get_mut() = SubscribeState::Pending(r);
                         return true;