diff --git a/snakemake/executors/__init__.py b/snakemake/executors/__init__.py index 06089242a..0f42fba3d 100644 --- a/snakemake/executors/__init__.py +++ b/snakemake/executors/__init__.py @@ -1073,7 +1073,7 @@ def _wait_for_jobs(self): success = "success" failed = "failed" running = "running" - status_cmd_kills = set() + status_cmd_kills = [] if self.statuscmd is not None: def job_status(job, valid_returns=["running", "success", "failed"]): @@ -1093,7 +1093,7 @@ def job_status(job, valid_returns=["running", "success", "failed"]): # snakemake. # Snakemake will handle the signal in # the main process. - status_cmd_kills.add(e.returncode) + status_cmd_kills.append(-e.returncode) if len(status_cmd_kills) > 10: logger.info( "Cluster status command {} was killed >10 times with signal(s) {} "