diff --git a/coordinator/ProcessorServer.py b/coordinator/ProcessorServer.py index d8aad9beb9c856fa595d36d30633ce1b12f66879..50a68f17d64386fbd8b69a052ce9107a30a6f511 100644 --- a/coordinator/ProcessorServer.py +++ b/coordinator/ProcessorServer.py @@ -54,7 +54,8 @@ def process_pre_job_server_download(input_args: dict): description_short = 'subprocess_ssh' description_long = f"Checking for existence of {file_path}/{file_name}.tar.gz" - status = subprocess_and_log(cmd_ssh,description_short,description_long,check=False) + status = subprocess_and_log(cmd_check_file, description_short, description_long, check = False, + shell = run_in_shell) if status.returncode > 0: