Fix max process workers flag (#496)

NVIDIA · Feb 27, 2025 · 48d0fb5 · 48d0fb5
1 parent 1e3493a
commit 48d0fb5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/nv_ingest/util/multi_processing/mp_pool_singleton.py b/src/nv_ingest/util/multi_processing/mp_pool_singleton.py
@@ -152,7 +152,7 @@ def __new__(cls):
             if cls._instance is None:
                 max_worker_limit = int(os.environ.get("MAX_INGEST_PROCESS_WORKERS", -1))
                 cls._instance = super(ProcessWorkerPoolSingleton, cls).__new__(cls)
-                max_workers = min(max_worker_limit, math.floor(max(1, len(os.sched_getaffinity(0)) * 0.4)))
+                max_workers = math.floor(max(1, len(os.sched_getaffinity(0)) * 0.4))
                 if (max_worker_limit > 0) and (max_workers > max_worker_limit):
                     max_workers = max_worker_limit
                 logger.debug("Creating ProcessWorkerPoolSingleton instance with max workers: %d", max_workers)