

def async_barrier(self):
    fr = self.future_responses[:]
    exceptions = []
    for r in fr:
        try:
            self.async_response(r)
        except Exception as e:
            exceptions.append(e)
    if exceptions:
        raise Exception(max(exceptions))

dataset/ETHPy150Open EricssonResearch/calvin-base/calvin/requests/request_handler.py RequestHandler.async_barrier/original