Skip to content

Commit f0f8573

Browse files
committed
fix memory leak bug
1 parent 71d6d8f commit f0f8573

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

executor/engine/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
from .core import Engine, EngineSetting
22
from .job import LocalJob, ThreadJob, ProcessJob
33

4-
__version__ = '0.3.0'
4+
__version__ = '0.3.1'
55

66
__all__ = [
77
'Engine', 'EngineSetting',

executor/engine/job/process.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,9 @@
22
import functools
33
from inspect import iscoroutinefunction
44

5+
import loky.process_executor
6+
if hasattr(loky.process_executor, "_MAX_MEMORY_LEAK_SIZE"):
7+
loky.process_executor._MAX_MEMORY_LEAK_SIZE = int(1e13)
58
from loky.process_executor import ProcessPoolExecutor
69

710
from .base import Job

0 commit comments

Comments
 (0)