mypy

openclimatefix · Jan 2, 2025 · 8cef147 · 8cef147
1 parent 9154578
commit 8cef147
Showing 1 changed file with 4 additions 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,10 @@ 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(str(os.getenv("NUMBER_CONCURRENT_JOBS")))
+            number_of_current_jobs = os.getenv("NUMBER_CONCURRENT_JOBS")
+            assert number_of_current_jobs is not None
+            assert number_of_current_jobs.isnumeric()
+            n_jobs = int(number_of_current_jobs)
         log.debug(f"Using {n_jobs} concurrent thread(s)")
 
         return Parallel(  # type: ignore