2026-05-22 09:15:05 +00:00
1 changed files with 1 additions and 3 deletions
@@ -22,11 +22,9 @@ pub fn scatter(
    use obikseq::RoutableSuperKmer;

    let t = Stage::start("scatter");
-    let path_source = path_source.inspect(|p| info!("indexing: {}", p.display()));
-
    let pipe = obipipeline::make_pipe! {
        PipelineData : PathBuf => Vec<RoutableSuperKmer>,
-        ||? { |path| open_chunks(path) }                                               : Path     => RawChunk,
+        ||? { |path: PathBuf| { info!("indexing: {}", path.display()); open_chunks(path) } } : Path => RawChunk,
        |?  { move |rope| obiread::normalize_sequence_chunk(rope, k) }                : RawChunk => NormChunk,
        |   { move |rope| obiskbuilder::build_superkmers(rope, k, level_max, theta) }: NormChunk => Batch,
    };