Message280958
To tie in the example given by @elias in issue28625, this inconsistency in behavior is not limited to ThreadPool -- it appears with a process Pool as well:
from multiprocessing import Pool
def double(x):
return 2 * x
def get_numbers():
raise Exception("oops")
yield 1
yield 2
>>> list(Pool(processes=2).imap(double, get_numbers())) # returns list
[]
>>> list(Pool(processes=2).map(double, get_numbers()))
Traceback (most recent call last):
...
Exception: oops
def get_numbers_differently():
yield 1
raise Exception("oops")
yield 2
>>> list(Pool(processes=2).imap(double, get_numbers_differently())) # now we see exception
Traceback (most recent call last):
...
Exception: oops |
|
Date |
User |
Action |
Args |
2016-11-16 14:54:30 | davin | set | recipients:
+ davin, elias, lev-veshnyakov |
2016-11-16 14:54:30 | davin | set | messageid: <1479308070.78.0.651580630815.issue28699@psf.upfronthosting.co.za> |
2016-11-16 14:54:30 | davin | link | issue28699 messages |
2016-11-16 14:54:30 | davin | create | |
|