This commit is contained in:
Bojan Serafimov
2022-05-22 15:53:52 -04:00
parent 13b374a2df
commit 5a19ac02c9

View File

@@ -30,6 +30,8 @@ impl<J: Job> Pool<J> {
if let Some(command) = q.pop_front() {
drop(q);
match command {
// TODO catch unwind. On error:
// - report back so that only that tenant would get stuck
WorkerCommand::DoJob(job) => job.run(),
WorkerCommand::Shutdown => return Ok(()),
}