From d6499b4ad133997ddad41e72d25fc6e0dea32935 Mon Sep 17 00:00:00 2001 From: BobTheBuidler Date: Mon, 22 Apr 2024 17:14:28 +0000 Subject: [PATCH] fix: union --- a_sync/primitives/queue.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/a_sync/primitives/queue.py b/a_sync/primitives/queue.py index bf69b5ad..9ab79d9d 100644 --- a/a_sync/primitives/queue.py +++ b/a_sync/primitives/queue.py @@ -210,7 +210,13 @@ class VariablePriorityQueue(_VariablePriorityQueueMixin[T], asyncio.PriorityQueu class SmartProcessingQueue(_VariablePriorityQueueMixin[T], ProcessingQueue[Concatenate[T, P], V]): """A PriorityProcessingQueue subclass that will execute jobs with the most waiters first""" _no_futs = False - def __init__(self, func: Callable[Concatenate[T, P], Awaitable[V]], num_workers: int, *, loop: asyncio.AbstractEventLoop | None = None) -> None: + def __init__( + self, + func: Callable[Concatenate[T, P], Awaitable[V]], + num_workers: int, + *, + loop: Optional[asyncio.AbstractEventLoop] = None, + ) -> None: super().__init__(func, num_workers, return_data=True, loop=loop) async def put(self, *args: P.args, **kwargs: P.kwargs) -> "asyncio.Future[V]": self._workers