Multithread distances task in miga doctor

bio-miga · Mar 20, 2024 · 6ade0b4 · 6ade0b4
1 parent b43d9b1
commit 6ade0b4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/lib/miga/cli/action/doctor/base.rb b/lib/miga/cli/action/doctor/base.rb
@@ -37,10 +37,11 @@ def check_dist_fix(cli, p, fix)
     return if fix.empty?
 
     cli.say("- Fixing #{fix.size} datasets")
-    fix.each_with_index do |d_n, k|
-      cli.advance('  > Fixing', k + 1, fix.size, false)
+    MiGA::Parallel.distribute(fix, cli[:threads]) do |d_n, idx, thr|
+      cli.advance('  > Fixing', idx + 1, fix.size, false) if thr == 0
       p.dataset(d_n).cleanup_distances!
     end
+    cli.say
   end
 
   ##

diff --git a/lib/miga/version.rb b/lib/miga/version.rb
@@ -12,7 +12,7 @@ module MiGA
   # - String indicating release status:
   #   - rc* release candidate, not released as gem
   #   - [0-9]+ stable release, released as gem
-  VERSION = [1.3, 13, 4].freeze
+  VERSION = [1.3, 13, 5].freeze
 
   ##
   # Nickname for the current major.minor version.