rmanach/deployer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

lint fixes

Browse Source
This commit is contained in:
rmanach 2023-04-22 15:34:52 +02:00
parent 42da6f8840
commit 407611bba1
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/worker/worker.rs
View File

@ -107,12 +107,10 @@ impl<H: Handler, N: Notifier> Worker<H, N> {
Worker::<H, N>::set_status(&status, WorkerStatus::Running); Worker::<H, N>::set_status(&status, WorkerStatus::Running);
// TODO: the message could be requeued if needed // TODO: the message could be requeued if needed
if let Err(e) = handler.handle(runner.run()) { if let Err(HandlerError::Unknown) = handler.handle(runner.run()) {
if let HandlerError::Unknown = e {
Worker::<H, N>::set_status(&status, WorkerStatus::Failed); Worker::<H, N>::set_status(&status, WorkerStatus::Failed);
break; break;
} }
}
// TODO: collect a message from the handler (modify the signature) // TODO: collect a message from the handler (modify the signature)
notifier.send(Message::empty()); notifier.send(Message::empty());
Worker::<H, N>::set_status(&status, WorkerStatus::Pending); Worker::<H, N>::set_status(&status, WorkerStatus::Pending);