mypy fix

openclimatefix · Jan 2, 2025 · 9154578 · 9154578
1 parent c13ba38
commit 9154578
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/nwp_consumer/internal/services/consumer_service.py b/src/nwp_consumer/internal/services/consumer_service.py
@@ -110,7 +110,7 @@ def _parallelize_generator[T](
         if os.getenv("CONCURRENCY", "True").capitalize() == "False":
             n_jobs = 1
         elif os.getenv("NUMBER_CONCURRENT_JOBS") is not None:
-            n_jobs = int(os.getenv("NUMBER_CONCURRENT_JOBS"))
+            n_jobs = int(str(os.getenv("NUMBER_CONCURRENT_JOBS")))
         log.debug(f"Using {n_jobs} concurrent thread(s)")
 
         return Parallel(  # type: ignore