chore: drop sync

Author: ovr

rust/cubestore/cubestore/src/cachestore/cache_rocksstore.rs

@@ -1300,12 +1300,7 @@ impl CacheStore for RocksCacheStore {
                 queue_schema.update(id_row.id, new, id_row.get_row(), batch_pipe)?;
                 Ok(())
             } else {
-                trace!(
-                    "Unable to update heartbeat , unknown
-                    key
-                : {:?}",
-                    key
-                );
+                trace!("Unable to update heartbeat, unknown key: {:?}", key);
 
                 Ok(())
             }

rust/cubestore/cubestore/src/metastore/rocks_store.rs

@@ -808,16 +808,14 @@ pub trait RocksStoreDetails: Send + Sync {
 #[derive(Debug, Clone)]
 pub struct RocksStoreRWLoop {
     name: &'static str,
-    tx: tokio::sync::mpsc::Sender<
-        Box<dyn FnOnce() -> Result<(), CubeError> + Send + Sync + 'static>,
-    >,
+    tx: tokio::sync::mpsc::Sender<Box<dyn FnOnce() -> Result<(), CubeError> + Send + 'static>>,
     _join_handle: Arc<AbortingJoinHandle<()>>,
 }
 
 impl RocksStoreRWLoop {
     pub fn new(name: &'static str) -> Self {
         let (tx, mut rx) = tokio::sync::mpsc::channel::<
-            Box<dyn FnOnce() -> Result<(), CubeError> + Send + Sync + 'static>,
+            Box<dyn FnOnce() -> Result<(), CubeError> + Send + 'static>,
         >(32_768);
 
         let join_handle = cube_ext::spawn_blocking(move || loop {