1 files changed, 1 insertions, 5 deletions
diff --git a/src/main.rs b/src/main.rs
index 122ce60..d1e4562 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -116,11 +116,7 @@ fn main() -> Result<()> {
     if args.get_flag("doit") {
         let hanlder = running.clone();
         let threads = *args.get_one::<usize>("threads").unwrap();
-        let pool = rayon::ThreadPoolBuilder::new()
-            .num_threads(threads)
-            .build()?;
-
-        pool.install(|| files::reencode_files(conn, hanlder))?;
+        files::reencode_files(conn, hanlder, threads)?;
     }
     Ok::<(), anyhow::Error>(())
 }