asonix/background-jobs
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Warn about working closing on drop

Browse source
This commit is contained in:
Aode (Lion) 2021-10-06 21:20:17 -05:00
parent 1266873f5d
commit 5cd6a1b102
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
jobs-actix/src/worker.rs
View file

@ -42,6 +42,14 @@ impl Worker for LocalWorkerHandle {
} }
} }
struct WarnOnDrop(Uuid);
impl Drop for WarnOnDrop {
fn drop(&mut self) {
warn!("Worker {} closing", self.0);
}
}
pub(crate) fn local_worker<State>( pub(crate) fn local_worker<State>(
queue: String, queue: String,
processors: CachedProcessorMap<State>, processors: CachedProcessorMap<State>,
@ -56,6 +64,7 @@ pub(crate) fn local_worker<State>(
let handle = LocalWorkerHandle { tx, id, queue }; let handle = LocalWorkerHandle { tx, id, queue };
spawn(async move { spawn(async move {
let warn_on_drop = WarnOnDrop(id);
debug!("Beginning worker loop for {}", id); debug!("Beginning worker loop for {}", id);
if let Err(e) = server.request_job(Box::new(handle.clone())).await { if let Err(e) = server.request_job(Box::new(handle.clone())).await {
error!("Couldn't request first job, bailing, {}", e); error!("Couldn't request first job, bailing, {}", e);
@ -72,6 +81,6 @@ pub(crate) fn local_worker<State>(
break; break;
} }
} }
warn!("Worker {} closing", id); drop(warn_on_drop);
}); });
} }