initialize backend threads

lenskit · May 10, 2024 · c4c68ab · c4c68ab
1 parent 5562980
commit c4c68ab
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lenskit/parallel/worker.py b/lenskit/parallel/worker.py
@@ -42,7 +42,7 @@ class WorkerContext(NamedTuple, Generic[M, A, R]):
 def initalize(cfg: WorkerConfig, ctx: ModelData) -> None:
     global __work_context
     manylog.init_worker_logging(cfg.log_addr)
-    init_parallel(processes=1, threads=cfg.threads, child_threads=1)
+    init_parallel(processes=1, threads=1, backend_threads=cfg.threads, child_threads=1)
 
     seed = seedbank.derive_seed(mp.current_process().name, base=cfg.seed)
     seedbank.initialize(seed)