aboutsummaryrefslogtreecommitdiff
path: root/wqflask/wqflask
diff options
context:
space:
mode:
authorZachary Sloan2013-04-18 22:36:39 +0000
committerZachary Sloan2013-04-18 22:36:39 +0000
commit5ffd0debd5ab7ee0e98def74374a8e996629f5c9 (patch)
tree74fd7f83e9d94d49f6e77a009f5d39e6081aa019 /wqflask/wqflask
parentf36de42faa6565a04c344071a3a4befa60879509 (diff)
downloadgenenetwork2-5ffd0debd5ab7ee0e98def74374a8e996629f5c9.tar.gz
The plink_input is split into chunks that are stored in temp_data, but
we might decide to store it differently
Diffstat (limited to 'wqflask/wqflask')
-rw-r--r--wqflask/wqflask/my_pylmm/pyLMM/lmm.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/wqflask/wqflask/my_pylmm/pyLMM/lmm.py b/wqflask/wqflask/my_pylmm/pyLMM/lmm.py
index 8c0e0282..a6134fdd 100644
--- a/wqflask/wqflask/my_pylmm/pyLMM/lmm.py
+++ b/wqflask/wqflask/my_pylmm/pyLMM/lmm.py
@@ -89,13 +89,13 @@ def run_human(pheno_vector,
with Bench("Divide into chunks"):
results = chunks.divide_into_chunks(inputs, 64)
-
+
result_store = []
identifier = uuid.uuid4()
for part, result in enumerate(results):
- data_store = temp_data.TempData(identifier, part)
+ data_store = temp_data.TempData(identifier, "plink", part)
- data_store.store(data=pickle.dumps(result))
+ data_store.store("data", pickle.dumps(result, pickle.HIGHEST_PROTOCOL))
result_store.append(data_store)
for snp, this_id in plink_input:
@@ -103,7 +103,7 @@ def run_human(pheno_vector,
if count > 2000:
break
count += 1
-
+
percent_complete = (float(count) / total_snps) * 100
#print("percent_complete: ", percent_complete)
loading_progress.store("percent_complete", percent_complete)