(self)
| 548 | raise exceptions.BrokenBarrierError("Barrier aborted") |
| 549 | |
| 550 | async def _release(self): |
| 551 | # Release the tasks waiting in the barrier. |
| 552 | |
| 553 | # Enter draining state. |
| 554 | # Next waiting tasks will be blocked until the end of draining. |
| 555 | self._state = _BarrierState.DRAINING |
| 556 | self._cond.notify_all() |
| 557 | |
| 558 | async def _wait(self): |
| 559 | # Wait in the barrier until we are released. Raise an exception |