(&mut self)
| 179 | |
| 180 | impl<K, V> Drop for SpillCore<K, V> { |
| 181 | fn drop(&mut self) { |
| 182 | // tempfile handles auto-delete each file via OS-level unlink on close. |
| 183 | self.runs.clear(); |
| 184 | if let Err(e) = std::fs::remove_dir(&self.spill_dir) |
| 185 | && self.spill_dir.exists() |
| 186 | { |
| 187 | tracing::warn!( |
| 188 | dir = %self.spill_dir.display(), |
| 189 | error = %e, |
| 190 | "groupby_spill: could not remove spill directory" |
| 191 | ); |
| 192 | } |
| 193 | } |
| 194 | } |