OBIKmers/obikmer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request 'refactor(scatter): move logging call into pipeline closure' (#5) from push-txyqunyttswl into main

Browse Source 
Reviewed-on: #5
This commit was merged in pull request #5.
This commit is contained in:
coissac
2026-05-22 09:15:05 +00:00
parent df28cadc41 9b37e848d4
commit 1ba6690256
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/obikmer/src/steps/scatter.rs
+1 -3
View File
@@ -22,11 +22,9 @@ pub fn scatter(
use obikseq::RoutableSuperKmer; use obikseq::RoutableSuperKmer;
let t = Stage::start("scatter"); let t = Stage::start("scatter");
let path_source = path_source.inspect(|p| info!("indexing: {}", p.display()));
let pipe = obipipeline::make_pipe! { let pipe = obipipeline::make_pipe! {
PipelineData : PathBuf => Vec<RoutableSuperKmer>, 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| obiread::normalize_sequence_chunk(rope, k) } : RawChunk => NormChunk,
| { move |rope| obiskbuilder::build_superkmers(rope, k, level_max, theta) }: NormChunk => Batch, | { move |rope| obiskbuilder::build_superkmers(rope, k, level_max, theta) }: NormChunk => Batch,
}; };