loco version support local and normal

src/bgworker/mod.rs

@@ -2,7 +2,6 @@ use std::sync::Arc;
 
 use async_trait::async_trait;
 use serde::Serialize;
-use tokio_util::sync::CancellationToken;
 use tracing::{debug, error};
 #[cfg(feature = "bg_pg")]
 pub mod pg;
@@ -21,7 +20,7 @@ pub enum Queue {
     Redis(
         bb8::Pool<sidekiq::RedisConnectionManager>,
         Arc<tokio::sync::Mutex<sidekiq::Processor>>,
-        CancellationToken,
+        tokio_util::sync::CancellationToken,
     ),
     #[cfg(feature = "bg_pg")]
     Postgres(
@@ -38,6 +37,7 @@ impl Queue {
     /// # Errors
     ///
     /// This function will return an error if fails
+    #[allow(unused_variables)]
     pub async fn enqueue<A: Serialize + Send + Sync>(
         &self,
         class: String,
@@ -72,6 +72,7 @@ impl Queue {
     /// # Errors
     ///
     /// This function will return an error if fails
+    #[allow(unused_variables)]
     pub async fn register<
         A: Serialize + Send + Sync + 'static + for<'de> serde::Deserialize<'de>,
         W: BackgroundWorker<A> + 'static,
@@ -200,8 +201,8 @@ impl Queue {
 
     /// # Errors
     ///
-    /// Does not currently return an error, but the postgres or other future queue implementations
-    /// might, so using Result here as return type.
+    /// Does not currently return an error, but the postgres or other future
+    /// queue implementations might, so using Result here as return type.
     pub fn shutdown(&self) -> Result<()> {
         println!("waiting for running jobs to finish...");
         match self {