Set maximum amount of memory each worker process can allocate.
(limit)
| 90 | |
| 91 | |
| 92 | def initializer(limit): |
| 93 | """Set maximum amount of memory each worker process can allocate.""" |
| 94 | soft, hard = resource.getrlimit(resource.RLIMIT_AS) |
| 95 | resource.setrlimit(resource.RLIMIT_AS, (limit, hard)) |
| 96 | |
| 97 | |
| 98 | def run_tasks_in_parallel_iter( |
nothing calls this directly
no outgoing calls
no test coverage detected