diff options
| author | Alexander_Kabui | 2025-01-09 10:44:32 +0300 |
|---|---|---|
| committer | Alexander_Kabui | 2025-01-09 10:44:32 +0300 |
| commit | ba21ca6f6d237f3e2d30a65d44300688e521d10f (patch) | |
| tree | 4badde45db5152cd7aeacb05dafe681c9475fe76 /gn3/api | |
| parent | f73605a67d3521e9a5cea86bdd5a947cf574f061 (diff) | |
| download | genenetwork3-ba21ca6f6d237f3e2d30a65d44300688e521d10f.tar.gz | |
refactor: remove obsolete streaming endpoint.
Diffstat (limited to 'gn3/api')
| -rw-r--r-- | gn3/api/rqtl2.py | 16 |
1 files changed, 0 insertions, 16 deletions
diff --git a/gn3/api/rqtl2.py b/gn3/api/rqtl2.py index a6ac411..e26b9ed 100644 --- a/gn3/api/rqtl2.py +++ b/gn3/api/rqtl2.py @@ -45,19 +45,3 @@ def compute(): return jsonify({"msg": "fail", "error": "Process failed", "run_id": run_id}) - - -@rqtl2.route("/stream/<identifier>", methods=["GET"]) -def stream(identifier="output"): - """ This endpoints streams stdout from a file expects - the indetifier to be the file """ - output_file = os.path.join(current_app.config.get("TMPDIR"), - f"{identifier}.txt") - seek_position = int(request.args.get("peak", 0)) - with open(output_file, encoding="utf-8") as file_handler: - # read to the last position default to 0 - file_handler.seek(seek_position) - results = {"data": file_handler.readlines(), - "run_id": identifier, - "pointer": file_handler.tell()} - return jsonify(results) |
