diff --git a/coordinator/ProcessorServer.py b/coordinator/ProcessorServer.py index 3593fdd97159dda28130023f9931021916f1bafa..c3f3bf8f6ec4d6b4c5a585aa8515f9df52ccd38f 100644 --- a/coordinator/ProcessorServer.py +++ b/coordinator/ProcessorServer.py @@ -61,7 +61,7 @@ def process_pre_job_server_download(input_args: dict): status = subprocess_and_log(cmd_check_file, description_short, description_long, check = False, shell = run_in_shell) - data_is_ready = status.returncode > 0 + data_is_ready = status.returncode == 0 if not data_is_ready: @@ -97,7 +97,7 @@ def process_pre_job_server_download(input_args: dict): logger.info(message) endScript(premature=True) - elif not data_is_ready: + elif data_is_ready: logger.info(f"Data is available for config {i+1} of {len(config_paths)}, calculation shall proceed") return True