chore: assert that jobcount is unrestricted if no max-jobs-per-timespan is set

johanneskoester · johanneskoester · commit c11597dfd020 · 2024-09-04T11:18:40.000+02:00
diff --git a/snakemake/scheduler.py b/snakemake/scheduler.py
@@ -62,7 +62,6 @@ def __init__(self, workflow, executor_plugin: ExecutorPlugin):
         self.failed = set()
         self.finished_jobs = 0
         self.greediness = self.workflow.scheduling_settings.greediness
-        self.max_jobs_per_second = self.workflow.scheduling_settings.max_jobs_per_second
         self._tofinish = []
         self._toerror = []
         self.handle_job_success = True
@@ -475,6 +474,8 @@ def exit_gracefully(self, *args):
     def job_selector(self, jobs):
         # get number of free jobs to submit
         if self.job_rate_limiter is None:
+            # ensure that the job count is not restricted
+            assert self.resources["_job_count"] == sys.maxsize
             return self._job_selector(jobs)
         n_free_jobs = self.job_rate_limiter.get_free_jobs()
         if n_free_jobs == 0:
