fix: comparison to float in scheduler

snakemake · Oct 23, 2023 · ef44d84 · ef44d84
1 parent a79dd94
commit ef44d84
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/snakemake/scheduler.py b/snakemake/scheduler.py
@@ -5,6 +5,7 @@
 
 import asyncio
 from collections import defaultdict
+import math
 import os, signal, sys
 import threading
 
@@ -571,7 +572,9 @@ async def get_temp_sizes_gb():
             return self.job_selector_greedy(jobs)
 
         selected_jobs = set(
-            job for job, variable in scheduled_jobs.items() if variable.value() == 1.0
+            job
+            for job, variable in scheduled_jobs.items()
+            if math.isclose(variable.value(), 1.0)
         )
 
         if not selected_jobs: