lint: cargo clippy

geofmureithi · Dec 1, 2024 · a383e5d · a383e5d
1 parent 0cc6dc3
commit a383e5d
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/packages/apalis-sql/src/mysql.rs b/packages/apalis-sql/src/mysql.rs
@@ -418,7 +418,7 @@ where
         let mut hb_storage = self.clone();
         let requeue_storage = self.clone();
         let stream = self
-            .stream_jobs(&worker, config.poll_interval, config.buffer_size)
+            .stream_jobs(worker, config.poll_interval, config.buffer_size)
             .map_err(|e| Error::SourceError(Arc::new(Box::new(e))));
         let stream = BackendStream::new(stream.boxed(), controller);
         let w = worker.clone();

diff --git a/packages/apalis-sql/src/postgres.rs b/packages/apalis-sql/src/postgres.rs
@@ -485,7 +485,7 @@ where
             .bind(args)
             .bind(req.parts.task_id.to_string())
             .bind(&job_type)
-            .bind(&req.parts.context.max_attempts())
+            .bind(req.parts.context.max_attempts())
             .execute(&self.pool)
             .await?;
         Ok(req.parts)
@@ -508,7 +508,7 @@ where
             .bind(job)
             .bind(task_id)
             .bind(job_type)
-            .bind(&parts.context.max_attempts())
+            .bind(parts.context.max_attempts())
             .bind(on)
             .execute(&self.pool)
             .await?;

diff --git a/packages/apalis-sql/src/sqlite.rs b/packages/apalis-sql/src/sqlite.rs
@@ -206,7 +206,7 @@ where
                     .fetch_all(&mut *tx)
                     .await?;
                 for id in ids {
-                    let res = fetch_next(&pool, &worker_id, id.0, &config).await?;
+                    let res = fetch_next(&pool, worker_id, id.0, &config).await?;
                     yield match res {
                         None => None::<Request<T, SqlContext>>,
                         Some(job) => {
@@ -248,7 +248,7 @@ where
             .bind(raw)
             .bind(parts.task_id.to_string())
             .bind(job_type.to_string())
-            .bind(&parts.context.max_attempts())
+            .bind(parts.context.max_attempts())
             .execute(&self.pool)
             .await?;
         Ok(parts)
@@ -269,7 +269,7 @@ where
             .bind(job)
             .bind(id.to_string())
             .bind(job_type)
-            .bind(&req.parts.context.max_attempts())
+            .bind(req.parts.context.max_attempts())
             .bind(on)
             .execute(&self.pool)
             .await?;
@@ -476,7 +476,7 @@ impl<T: Serialize + DeserializeOwned + Sync + Send + Unpin + 'static, Res>
         let config = self.config.clone();
         let controller = self.controller.clone();
         let stream = self
-            .stream_jobs(&worker, config.poll_interval, config.buffer_size)
+            .stream_jobs(worker, config.poll_interval, config.buffer_size)
             .map_err(|e| Error::SourceError(Arc::new(Box::new(e))));
         let stream = BackendStream::new(stream.boxed(), controller);
         let requeue_storage = self.clone();