Исключение в многопроцессорном пуле не обнаружено

Похоже, что когда возникает исключение из процесса multiprocessing.Pool, нет трассировки стека или любого другого признака сбоя. Пример:

from multiprocessing import Pool 

def go():
    print(1)
    raise Exception()
    print(2)

p = Pool()
p.apply_async(go)
p.close()
p.join()

печатает 1 и молча останавливается. Интересно, что вместо этого работает создание исключения BaseException. Есть ли способ сделать поведение всех исключений таким же, как BaseException?

64
задан Rob Lourens 18 July 2011 в 02:46
поделиться