chore: clippy

anchor-service/src/anchor_batch.rs

@@ -290,13 +290,13 @@ mod tests {
         );
         let (shutdown_signal_tx, mut shutdown_signal) = broadcast::channel::<()>(1);
         // let mut shutdown_signal = shutdown_signal_rx.resubscribe();
-        Some(tokio::spawn(async move {
+        tokio::spawn(async move {
             anchor_service
                 .run(async move {
                     let _ = shutdown_signal.recv().await;
                 })
                 .await
-        }));
+        });
         while event_service.events.lock().unwrap().is_empty() {
             sleep(Duration::from_millis(1)).await;
         }

event-svc/src/tests/event.rs

@@ -729,7 +729,7 @@ fn events_to_table(conclusion_events: &[ConclusionEvent]) -> String {
                     .join(", ")
             )),
             Cell::new(&event_cid.to_string()),
-            Cell::new(&data),
+            Cell::new(data),
             Cell::new(&previous),
         ]));
     }

event-svc/src/tests/mod.rs

@@ -58,7 +58,7 @@ pub(crate) fn random_cid() -> Cid {
     Cid::new_v1(0x00, hash)
 }
 pub(crate) fn deterministic_cid(data: &[u8]) -> Cid {
-    let hash = MultihashDigest::digest(&Code::Sha2_256, &data);
+    let hash = MultihashDigest::digest(&Code::Sha2_256, data);
     Cid::new_v1(0x00, hash)
 }
 

flight/tests/server.rs

@@ -70,7 +70,7 @@ async fn execute_flight(
         batches.append(&mut endpoint_batches);
     }
 
-    Ok(concat_batches(&schema, &batches).context("concat_batches for output")?)
+    concat_batches(&schema, &batches).context("concat_batches for output")
 }
 
 mock! {