From a8875964d6de843faa449c261aac8b09e1bfa423 Mon Sep 17 00:00:00 2001 From: Albert Zeyer Date: Tue, 9 Jan 2024 22:36:32 +0100 Subject: [PATCH] Slurm, fix submitting tasks multiple times (#169) 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)")