diff --git a/src/worker/worker.rs b/src/worker/worker.rs index f44e582..7bc3c9e 100644 --- a/src/worker/worker.rs +++ b/src/worker/worker.rs @@ -107,11 +107,9 @@ impl Worker { Worker::::set_status(&status, WorkerStatus::Running); // TODO: the message could be requeued if needed - if let Err(e) = handler.handle(runner.run()) { - if let HandlerError::Unknown = e { - Worker::::set_status(&status, WorkerStatus::Failed); - break; - } + if let Err(HandlerError::Unknown) = handler.handle(runner.run()) { + Worker::::set_status(&status, WorkerStatus::Failed); + break; } // TODO: collect a message from the handler (modify the signature) notifier.send(Message::empty());