From 310d731121b5496b87d6414b4609760419a81c2d Mon Sep 17 00:00:00 2001 From: Albert Zeyer Date: Tue, 9 Jan 2024 21:28:24 +0100 Subject: [PATCH] Slurm, fix submitting tasks multiple times submit_helper writes an invalid state to _task_info_cache, and then task_state returns STATE_UNKNOWN, which causes STATE_INTERRUPTED_RESUMABLE, which causes a resubmit. Fix #163 --- sisyphus/simple_linux_utility_for_resource_management_engine.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sisyphus/simple_linux_utility_for_resource_management_engine.py b/sisyphus/simple_linux_utility_for_resource_management_engine.py index 9292fb9..6621606 100644 --- a/sisyphus/simple_linux_utility_for_resource_management_engine.py +++ b/sisyphus/simple_linux_utility_for_resource_management_engine.py @@ -259,7 +259,7 @@ def submit_helper(self, call, logpath, rqmt, name, task_name, start_id, end_id, logging.info("Submitted with job_id: %s %s" % (job_id, name)) for task_id in range(start_id, end_id, step_size): - self._task_info_cache[(name, task_id)].append((job_id, "PD")) + self._task_info_cache[(name, task_id)].append((job_id, "PENDING")) if err: logging.warning(f"Got error while submitting job (but job {job_id} was submitted)")