Skip to content

Commit

Permalink
Modify error messages slightly
Browse files Browse the repository at this point in the history
  • Loading branch information
olliecheng committed Jan 4, 2025
1 parent 8eb9dbd commit 65b37af
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 1 deletion.
4 changes: 3 additions & 1 deletion src/call.rs
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,8 @@ pub fn consensus(
duplicates_only: bool,
output_originals: bool,
) -> Result<()> {
info!("Creating thread pool with {threads} threads");

rayon::ThreadPoolBuilder::new()
.num_threads(threads)
.build_global()?;
Expand All @@ -60,7 +62,7 @@ pub fn consensus(
idx += 1;

if (idx > 0) && (idx % 100000 == 0) {
eprintln!("Called {} reads...", idx);
info!("Called {} reads...", idx);
}

let single = group.records.len() == 1;
Expand Down
4 changes: 4 additions & 0 deletions src/duplicates.rs
Original file line number Diff line number Diff line change
Expand Up @@ -147,6 +147,8 @@ impl IndexReader {
///
/// This function will return an error if the file cannot be opened or read, or if the file format is incorrect.
pub fn get_duplicates(&mut self) -> Result<(DuplicateMap, DuplicateStatistics)> {
info!("Reading index file...");

let mut map = DuplicateMap::new();

let mut stats = DuplicateStatistics {
Expand Down Expand Up @@ -199,6 +201,8 @@ impl IndexReader {

stats.proportion_duplicate = stats.duplicate_reads as f64 / stats.total_reads as f64;

info!("Generated duplicate map from index file");

Ok((map, stats))
}
}

0 comments on commit 65b37af

Please sign in to comment.