fix warning in the example project
This commit is contained in:
parent
216bac0f7e
commit
ea5e740252
2 changed files with 7 additions and 7 deletions
|
@ -16,8 +16,8 @@ diesel-derive-enum = { version = "1", features = ["postgres"] }
|
|||
dotenv = "0.15"
|
||||
uuid = { version = "0.8", features = ["v4"] }
|
||||
chrono = "0.4"
|
||||
serde_json = "1.0"
|
||||
serde_json = "1"
|
||||
typetag = "0.1"
|
||||
log = "0.4"
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
thiserror = "1.0.29"
|
||||
serde = { version = "1", features = ["derive"] }
|
||||
thiserror = "1.0"
|
||||
|
|
|
@ -3,8 +3,8 @@ use fang::Queue;
|
|||
use fang::RetentionMode;
|
||||
use fang::WorkerParams;
|
||||
use fang::WorkerPool;
|
||||
use simple_worker::MyJob;
|
||||
use signal_hook::{consts::signal::*, iterator::Signals};
|
||||
use simple_worker::MyJob;
|
||||
|
||||
fn main() {
|
||||
dotenv().ok();
|
||||
|
@ -29,13 +29,13 @@ fn main() {
|
|||
println!("Received SIGINT");
|
||||
worker_pool.shutdown().unwrap();
|
||||
break;
|
||||
},
|
||||
}
|
||||
SIGTERM => {
|
||||
println!("Received SIGTERM");
|
||||
worker_pool.shutdown().unwrap();
|
||||
break;
|
||||
},
|
||||
_ => unreachable!(format!("Received unexpected signal: {:?}", sig)),
|
||||
}
|
||||
_ => unreachable!("Received unexpected signal: {:?}", sig),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue