

def add_exception(self, future):
    super(_AllCompletedWaiter, self).add_exception(future)
    if self.stop_on_exception:
        self.event.set()
    else:
        self._decrement_pending_calls()

dataset/ETHPy150Open AppScale/appscale/AppServer/lib/concurrent/concurrent/futures/_base.py _AllCompletedWaiter.add_exception/original