diff --git a/compute_tools/src/bin/fast_import.rs b/compute_tools/src/bin/fast_import.rs index 78acd78585..e65c210b23 100644 --- a/compute_tools/src/bin/fast_import.rs +++ b/compute_tools/src/bin/fast_import.rs @@ -339,6 +339,8 @@ async fn run_dump_restore( destination_connstring: String, ) -> Result<(), anyhow::Error> { let dumpdir = workdir.join("dumpdir"); + let num_jobs = num_cpus::get().to_string(); + info!("using {num_jobs} jobs for dump/restore"); let common_args = [ // schema mapping (prob suffices to specify them on one side) @@ -354,7 +356,7 @@ async fn run_dump_restore( "directory".to_string(), // concurrency "--jobs".to_string(), - num_cpus::get().to_string(), + num_jobs, // progress updates "--verbose".to_string(), ];