From b92af896d44a8e0c8fa91199859615d6390df8da Mon Sep 17 00:00:00 2001
From: Ayrat Badykov <ayratin555@gmail.com>
Date: Wed, 23 Jun 2021 14:30:19 +0300
Subject: [PATCH] fix clippy warnings

---
 src/executor.rs    |  2 +-
 src/postgres.rs    | 10 +++-------
 src/worker_pool.rs |  1 -
 3 files changed, 4 insertions(+), 9 deletions(-)

diff --git a/src/executor.rs b/src/executor.rs
index 1b0af54..c3d77b0 100644
--- a/src/executor.rs
+++ b/src/executor.rs
@@ -85,7 +85,7 @@ impl Executor {
 
     pub fn sleep(&mut self) {
         if self.sleep_period < self.max_sleep_period {
-            self.sleep_period = self.sleep_period + self.sleep_step;
+            self.sleep_period += self.sleep_step;
         }
 
         thread::sleep(Duration::from_secs(self.sleep_period));
diff --git a/src/postgres.rs b/src/postgres.rs
index af62601..a739b5c 100644
--- a/src/postgres.rs
+++ b/src/postgres.rs
@@ -37,15 +37,11 @@ impl Postgres {
 
         let url = match database_url {
             Some(string_url) => string_url,
-            None => {
-                let url = env::var("DATABASE_URL").expect("DATABASE_URL must be set");
-
-                url
-            }
+            None => env::var("DATABASE_URL").expect("DATABASE_URL must be set"),
         };
 
         let connection =
-            PgConnection::establish(&url).expect(&format!("Error connecting to {}", url));
+            PgConnection::establish(&url).unwrap_or_else(|_| panic!("Error connecting to {}", url));
 
         Self {
             connection,
@@ -85,7 +81,7 @@ impl Postgres {
         self.connection.transaction::<Option<Task>, Error, _>(|| {
             let found_task = self.fetch_task();
 
-            if let None = found_task {
+            if found_task.is_none() {
                 return Ok(None);
             }
 
diff --git a/src/worker_pool.rs b/src/worker_pool.rs
index 55b0b99..b7245ec 100644
--- a/src/worker_pool.rs
+++ b/src/worker_pool.rs
@@ -36,7 +36,6 @@ impl WorkerThread {
 
     pub fn spawn_in_pool(name: String, restarts: u64) {
         let mut builder = thread::Builder::new().name(name.clone());
-        builder = builder;
 
         info!(
             "starting a worker thread {}, number of restarts {}",