diff --git a/jobs-actix/src/lib.rs b/jobs-actix/src/lib.rs index b60011e..4c0b11c 100644 --- a/jobs-actix/src/lib.rs +++ b/jobs-actix/src/lib.rs @@ -244,6 +244,7 @@ struct DropNotifier { impl Drop for DropNotifier { fn drop(&mut self) { + tracing::warn!("DropNotifier dropped - Arbiter tearing down"); self.notify.notify_waiters(); } } @@ -270,9 +271,11 @@ impl Deref for ArbiterDropper { impl Drop for ArbiterDropper { fn drop(&mut self) { + tracing::warn!("Stopping and joining arbiter"); let arbiter = self.arbiter.take().unwrap(); arbiter.stop(); let _ = arbiter.join(); + tracing::warn!("Joined"); } }