style: apply cargo fmt to fix CI format check

Author: longzhi

src/beat/backend.rs

@@ -79,7 +79,9 @@ pub trait DistributedScheduler: Send {
         scheduled_tasks: &'a mut BinaryHeap<ScheduledTask>,
     ) -> Pin<Box<dyn Future<Output = Result<(), BeatError>> + Send + 'a>>;
 
-    fn shutdown<'a>(&'a mut self) -> Pin<Box<dyn Future<Output = Result<(), BeatError>> + Send + 'a>> {
+    fn shutdown<'a>(
+        &'a mut self,
+    ) -> Pin<Box<dyn Future<Output = Result<(), BeatError>> + Send + 'a>> {
         Box::pin(async { Ok(()) })
     }
 }

src/beat/backend/redis.rs

@@ -516,7 +516,9 @@ impl DistributedScheduler for RedisSchedulerBackend {
         })
     }
 
-    fn shutdown<'a>(&'a mut self) -> Pin<Box<dyn Future<Output = Result<(), BeatError>> + Send + 'a>> {
+    fn shutdown<'a>(
+        &'a mut self,
+    ) -> Pin<Box<dyn Future<Output = Result<(), BeatError>> + Send + 'a>> {
         Box::pin(async move {
             if self.state.is_leader {
                 if let Err(err) = self.release_lock().await {

src/beat/tests.rs

@@ -235,7 +235,8 @@ async fn test_beat_max_sleep_duration() {
             &mut self,
             _scheduled_tasks: &mut std::collections::BinaryHeap<ScheduledTask>,
         ) -> Result<(), BeatError> {
-            self.num_sync_calls.fetch_add(1, std::sync::atomic::Ordering::Relaxed);
+            self.num_sync_calls
+                .fetch_add(1, std::sync::atomic::Ordering::Relaxed);
             Ok(())
         }
     }