diff --git a/coordinator/ProcessorServer.py b/coordinator/ProcessorServer.py index c3f3bf8f6ec4d6b4c5a585aa8515f9df52ccd38f..0dd4dbd177c6f76f06acf27dff88614c63a7c6f1 100644 --- a/coordinator/ProcessorServer.py +++ b/coordinator/ProcessorServer.py @@ -52,7 +52,7 @@ def process_pre_job_server_download(input_args: dict): if server_name == "": # means the file is local data_is_ready = os.path.exists(full_file_path) and tarfile.is_tarfile(full_file_path) else: - cmd_check_file = ["ssh", "-i", config['ServerKey'], "-o", "StrictHostKeyChecking=no", server_name, + cmd_check_file = ["ssh", "-o", "StrictHostKeyChecking=no", server_name, f"test -f {full_file_path} && tar -tzf {full_file_path} >/dev/null"] run_in_shell: bool = False