Skip to content

Commit 08ba90c

Browse files
fix process pool for microsoft windows
1 parent 0fd5849 commit 08ba90c

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

sqlmesh/utils/process.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,12 @@ def map(self, fn, *iterables, timeout=None, chunksize=1):
5151
def create_process_pool_executor(
5252
initializer: t.Callable, initargs: t.Tuple, max_workers: t.Optional[int] = c.MAX_FORK_WORKERS
5353
) -> PoolExecutor:
54-
executor = SynchronousPoolExecutor if max_workers == 1 else ProcessPoolExecutor
55-
return executor(
54+
if max_workers == 1:
55+
return SynchronousPoolExecutor(
56+
initializer=initializer,
57+
initargs=initargs,
58+
)
59+
return ProcessPoolExecutor(
5660
mp_context=mp.get_context("fork"),
5761
initializer=initializer,
5862
initargs=initargs,

0 commit comments

Comments
 (0)