Re: [Python-Dev] [Python-checkins] bpo-5001: More-informative multiprocessing error messages (#3079)

https://github.com/python/cpython/commit/bd73e72b4a9f019be514954b1d40e64dc3a... commit: bd73e72b4a9f019be514954b1d40e64dc3a5e81c branch: master author: Allen W. Smith, Ph.D drallensmith@users.noreply.github.com committer: Antoine Pitrou pitrou@free.fr date: 2017-08-30T00:52:18+02:00 summary:
bpo-5001: More-informative multiprocessing error messages (#3079) ... @@ -254,8 +256,8 @@ def _setup_queues(self): def apply(self, func, args=(), kwds={}): ''' Equivalent of `func(*args, **kwds)`.
Pool must be running. '''
assert self._state == RUN
Also, this wasn't replaced with anything.
--Chris
return self.apply_async(func, args, kwds).get() def map(self, func, iterable, chunksize=None):
@@ -307,6 +309,10 @@ def imap(self, func, iterable, chunksize=1):

On Wed, 30 Aug 2017 03:21:42 -0700 Chris Jerdonek chris.jerdonek@gmail.com wrote:
https://github.com/python/cpython/commit/bd73e72b4a9f019be514954b1d40e64dc3a... commit: bd73e72b4a9f019be514954b1d40e64dc3a5e81c branch: master author: Allen W. Smith, Ph.D drallensmith@users.noreply.github.com committer: Antoine Pitrou pitrou@free.fr date: 2017-08-30T00:52:18+02:00 summary:
bpo-5001: More-informative multiprocessing error messages (#3079) ... @@ -254,8 +256,8 @@ def _setup_queues(self): def apply(self, func, args=(), kwds={}): ''' Equivalent of `func(*args, **kwds)`.
Pool must be running. '''
assert self._state == RUN
Also, this wasn't replaced with anything.
The check is already in apply_async(), checking it here again is redundant.
Regards
Antoine.
participants (2)
-
Antoine Pitrou
-
Chris Jerdonek