Unconditionally set mp_context for ProcessPoolExecutor

agronholm · Nov 19, 2024 · f791e3d · f791e3d
1 parent 798c6b1
commit f791e3d
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/apscheduler/executors/pool.py b/apscheduler/executors/pool.py
@@ -1,5 +1,5 @@
 import concurrent.futures
-import sys
+import multiprocessing
 from abc import abstractmethod
 from concurrent.futures.process import BrokenProcessPool
 
@@ -73,12 +73,6 @@ class ProcessPoolExecutor(BasePoolExecutor):
 
     def __init__(self, max_workers=10, pool_kwargs=None):
         pool_kwargs = pool_kwargs or {}
-
-        # On Python 3.14, "spawn" is the default mp_context
-        if sys.version_info < (3, 14):
-            import multiprocessing
-
-            pool_kwargs.setdefault("mp_context", multiprocessing.get_context("spawn"))
-
+        pool_kwargs.setdefault("mp_context", multiprocessing.get_context("spawn"))
         pool = concurrent.futures.ProcessPoolExecutor(int(max_workers), **pool_kwargs)
         super().__init__(pool)