Co-authored-by: Peter Bierma <zintensitydev@gmail.com>
def __init__(self, parties):
"""Create a barrier, initialised to 'parties' tasks."""
if parties < 1:
- raise ValueError('parties must be > 0')
+ raise ValueError('parties must be >= 1')
self._cond = Condition() # notify all tasks when state changes
"""
if parties < 1:
- raise ValueError("parties must be > 0")
+ raise ValueError("parties must be >= 1")
self._cond = Condition(Lock())
self._action = action
self._timeout = timeout
--- /dev/null
+Corrected :exc:`ValueError` message for :class:`asyncio.Barrier` and :class:`threading.Barrier`.