aboutsummaryrefslogtreecommitdiff
path: root/gn3/computations
diff options
context:
space:
mode:
authorAlexander Kabui2021-10-13 08:15:49 +0300
committerBonfaceKilz2021-10-25 14:16:21 +0300
commit7b8efdf2040b0f623d1736e5608338ddcbe4a9da (patch)
tree3967c1402e5170af10cc5e0abe03a6e06afd2096 /gn3/computations
parent4c2cf2aceb044d00fe5e41ac40a07fe614737ef2 (diff)
downloadgenenetwork3-7b8efdf2040b0f623d1736e5608338ddcbe4a9da.tar.gz
pylint and pep8 formatting
Diffstat (limited to 'gn3/computations')
-rw-r--r--gn3/computations/wgcna.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/gn3/computations/wgcna.py b/gn3/computations/wgcna.py
index 90db455..76c71d5 100644
--- a/gn3/computations/wgcna.py
+++ b/gn3/computations/wgcna.py
@@ -25,7 +25,7 @@ def dump_wgcna_data(request_data: dict):
return temp_file_path
-def stream_cmd_output(request_data, cmd: str):
+def stream_cmd_output(socketio, request_data, cmd: str):
"""function to stream in realtime"""
# xtodo syncing and closing /edge cases
@@ -41,7 +41,9 @@ def stream_cmd_output(request_data, cmd: str):
{"data": line}, namespace="/", room=request_data["socket_id"])
socketio.emit(
- "output", {"data": "parsing the output results"}, namespace="/", room=request_data["socket_id"])
+ "output", {"data":
+ "parsing the output results"}, namespace="/",
+ room=request_data["socket_id"])
def process_image(image_loc: str) -> bytes: