aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPjotr Prins2015-03-17 10:08:41 +0300
committerPjotr Prins2015-03-17 10:08:41 +0300
commit7268ed46c9bce6fea58b55723c325426bdeeb617 (patch)
tree1f308ba0bbf22e8a60e1efa1ae7a0f4f11779299
parent886934b9cf18cf092c5d6cd0667d860aa30e64b8 (diff)
downloadgenenetwork2-7268ed46c9bce6fea58b55723c325426bdeeb617.tar.gz
GWAS multi-core: Tweak queue
-rw-r--r--wqflask/wqflask/my_pylmm/pyLMM/gwas.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/wqflask/wqflask/my_pylmm/pyLMM/gwas.py b/wqflask/wqflask/my_pylmm/pyLMM/gwas.py
index f8d77ab6..2a472717 100644
--- a/wqflask/wqflask/my_pylmm/pyLMM/gwas.py
+++ b/wqflask/wqflask/my_pylmm/pyLMM/gwas.py
@@ -146,8 +146,8 @@ def gwas(Y,G,K,restricted_max_likelihood=True,refit=False,verbose=True):
completed += 1
except Queue.Empty:
pass
- if job > completed + cpu_num + 5:
- time.sleep(1)
+ if job > completed + cpu_num*2:
+ time.sleep(0.1)
else:
if job >= completed:
break