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 c33b758 commit 670dff8Copy full SHA for 670dff8
taskiq/receiver/receiver.py
@@ -70,7 +70,9 @@ def __init__( # noqa: WPS211
70
self.queue: DequeQueue[bytes] = DequeQueue()
71
72
self.sem_idle: Optional[asyncio.Semaphore] = None
73
- if max_idle_tasks and max_idle_tasks > 0:
+ if max_idle_tasks is not None and max_idle_tasks <= 0:
74
+ raise ValueError("`max_idle_tasks` should be greater then zero or None.")
75
+ if max_idle_tasks is not None and max_idle_tasks > 0:
76
self.sem_idle = asyncio.Semaphore(max_idle_tasks)
77
78
async def callback( # noqa: C901, WPS213
0 commit comments