We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent effb5a8 commit 14c84a6Copy full SHA for 14c84a6
src/async_utils/priority_sem.py
@@ -133,7 +133,9 @@ def __locked(self) -> bool:
133
# in the case of existing waiters
134
# not guaranteed to be immediately available
135
with self._internal_lock:
136
- return self._value == 0 or (any(not w.cancelled() for w in (self._waiters or ())))
+ return self._value == 0 or (
137
+ any(not w.cancelled() for w in (self._waiters or ()))
138
+ )
139
140
async def __aenter__(self) -> None:
141
prio = _priority.get()
0 commit comments