blob: e7469186b3a1d7d3d6aaa429ad461f64a82d4ee8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
""" File contains endpoints for rqlt2"""
import subprocess
import uuid
import os
from flask import current_app
from flask import jsonify
from flask import Blueprint
rqtl2 = Blueprint("rqtl2", __name__)
@rqtl2.route("/compute", methods=["GET"])
def compute():
"""Endpoint for computing QTL analysis using R/QTL2"""
wkdir = current_app.config.get("TMPDIR")
output_file = os.path.join(wkdir, "output.txt")
rscript_cmd = (
f"Rscript ./scripts/rqtl2_wrapper.R "
f"-i /home/kabui/r_playground/meta_grav.json "
f"-d /home/kabui/r_playground "
f"-o /home/kabui/r_playground/rqtl_output.json "
f"--nperm 100 --threshold 1 --cores 0"
)
process = subprocess.Popen(
rscript_cmd, shell=True,
stdout=subprocess.PIPE,
stderr=subprocess.STDOUT
)
# TODO rethink where we write this file
with open(output_file, "a+") as file_handler:
for line in iter(process.stdout.readline, b""):
file_handler.write(line.decode("utf-8"))
process.stdout.close()
process.wait()
if process.returncode == 0:
return jsonify({"msg": "success", "results": "file_here"})
else:
return jsonify({"msg": "fail", "error": "Process failed"})
|
