diff options
| author | Hynek Schlawack <hs@ox.cx> | 2012-10-27 10:53:02 (GMT) |
|---|---|---|
| committer | Hynek Schlawack <hs@ox.cx> | 2012-10-27 10:53:02 (GMT) |
| commit | 254af2644a90bcabbe2612950dd2a6ef408337be (patch) | |
| tree | 206fa794d5e883689a94b1856b0084d21ca7d0cc /Lib/multiprocessing | |
| parent | cc2f0421c70d6a68e026d074b7d1c7fa4d96e6b8 (diff) | |
| download | cpython-254af2644a90bcabbe2612950dd2a6ef408337be.zip cpython-254af2644a90bcabbe2612950dd2a6ef408337be.tar.gz cpython-254af2644a90bcabbe2612950dd2a6ef408337be.tar.bz2 | |
#16307: Fix multiprocessing.Pool.map_async not calling its callbacks
Patch by Janne Karila.
Diffstat (limited to 'Lib/multiprocessing')
| -rw-r--r-- | Lib/multiprocessing/pool.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/Lib/multiprocessing/pool.py b/Lib/multiprocessing/pool.py index ec57939..7f73b44 100644 --- a/Lib/multiprocessing/pool.py +++ b/Lib/multiprocessing/pool.py @@ -297,7 +297,8 @@ class Pool(object): ''' Asynchronous version of `map()` method. ''' - return self._map_async(func, iterable, mapstar, chunksize) + return self._map_async(func, iterable, mapstar, chunksize, callback, + error_callback) def _map_async(self, func, iterable, mapper, chunksize=None, callback=None, error_callback=None): |