in ingester/src/progress.rs [35:40]
fn drop(&mut self) { self.cancel.store(true, Relaxed); unsafe { ManuallyDrop::take(&mut self.thread) } .join() .unwrap(); }