about summary refs log tree commit diff
diff options
context:
space:
mode:
authorFrederick Muriuki Muriithi2026-04-09 12:33:44 -0500
committerFrederick Muriuki Muriithi2026-04-09 12:33:44 -0500
commit92286b4734963770ae3e6a930a5cd96c6ac430a4 (patch)
tree3de486402a924f8f4933c1d0293496fb1897b216
parent5e49a4be1866dea06d35d4c0a8004f8ccf9dd19e (diff)
downloadgn-uploader-92286b4734963770ae3e6a930a5cd96c6ac430a4.tar.gz
Use multiple threads to speed up the computations. HEAD main
-rw-r--r--scripts/run_qtlreaper.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/scripts/run_qtlreaper.py b/scripts/run_qtlreaper.py
index 5ab5b21..2269ea6 100644
--- a/scripts/run_qtlreaper.py
+++ b/scripts/run_qtlreaper.py
@@ -6,6 +6,7 @@ import time
 import secrets
 import logging
 import subprocess
+import multiprocessing
 from pathlib import Path
 from functools import reduce
 from typing import Union, Iterator
@@ -156,7 +157,8 @@ def dispatch(args: Namespace) -> int:
                      "--geno", _genofile,
                      "--traits", _traitsfile,
                      "--main_output", _qtlreaper_main_output,
-                     "--permu_output", _qtlreaper_permu_output),
+                     "--permu_output", _qtlreaper_permu_output,
+                     "--threads", str(int(1+(multiprocessing.cpu_count()/2)))),
                     env=({**os.environ, "RUST_BACKTRACE": "full"}
                          if logger.getEffectiveLevel() == logging.DEBUG
                          else dict(os.environ))) as _qtlreaper: