:param bool debug: `True` to turn on pickling error debug mode (slower); false by default.
super(LocalMultiprocessEngine, self).__init__(local_scheduler)
self._pool_size = pool_size if pool_size and pool_size > 0 else multiprocessing.cpu_count()
self._pool = multiprocessing.Pool(self._pool_size)
self._debug = debug
class Executor(FailSlowHelper):
After Change
TODO: disable by default, and enable in the pantsbuild/pants repo.
super(LocalMultiprocessEngine, self).__init__(scheduler)
self._pool_size = pool_size if pool_size and pool_size > 0 else 2 * multiprocessing.cpu_count()
self._pool = multiprocessing.Pool(self._pool_size)
self._debug = debug
class Executor(object):
