We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a786589 commit cc1ac3bCopy full SHA for cc1ac3b
taskiq/semaphore.py
@@ -52,7 +52,7 @@ async def acquire(self, first: bool = False) -> Literal[True]: # noqa: C901
52
Acquire a semaphore.
53
54
:param first: acquire ASAP
55
- :raises asyncio.exceptions.CancelledError: task cancelled
+ :raises asyncio.CancelledError: task cancelled
56
:returns: true
57
"""
58
if not self.locked():
@@ -78,7 +78,7 @@ async def acquire(self, first: bool = False) -> Literal[True]: # noqa: C901
78
else:
79
self._waiters.remove(fut)
80
81
- except asyncio.exceptions.CancelledError:
+ except asyncio.CancelledError:
82
if not fut.cancelled():
83
self._value += 1
84
self._wakeup_next()
0 commit comments