from multiprocessing.pool import ThreadPool def exception(_): raise ValueError('foo') pool = ThreadPool(1) pool.map(exception, [1])