Skip to content

Commit dc2bd50

Browse files
author
Vasu Jaganath
committed
fix the blocking calls in the async flow of run_local_async
1 parent 27d80a3 commit dc2bd50

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/sophios/run_local.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ def generate_run_script(cmdline: str) -> None:
5050

5151
def verify_container_engine_config(container_engine: str, ignore_container_install: bool) -> None:
5252
"""Verify that the container_engine is correctly installed and has
53-
correct permissions for the user.
53+
correct permissions for the user.
5454
Args:
5555
workflow_name (str): Name of the .cwl workflow file to be executed
5656
basepath (str): The path at which the workflow to be executed

src/sophios/run_local_async.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,8 +103,8 @@ async def run_cwl_serialized(workflow: Json, basepath: str,
103103
"""
104104
workflow_name = workflow['name']
105105
basepath = basepath.rstrip("/") if basepath != "/" else basepath
106-
output_dirs = pc.find_output_dirs(workflow)
107-
pc.create_output_dirs(output_dirs, basepath)
106+
output_dirs = await run_in_threadpool(pc.find_output_dirs, workflow)
107+
await run_in_threadpool(pc.create_output_dirs, output_dirs, basepath)
108108
compiled_cwl = workflow_name + '.cwl'
109109
inputs_yml = workflow_name + '_inputs.yml'
110110
# write _input.yml file

0 commit comments

Comments
 (0)