fix: pass _name to queue

BobTheBuidler · Apr 23, 2024 · 1511529 · 1511529
1 parent 1a76603
commit 1511529
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/a_sync/task.py b/a_sync/task.py
@@ -342,7 +342,7 @@ def _init_loader(self) -> "asyncio.Task[None]":
     @functools.cached_property
     def _queue(self) -> ProcessingQueue:
         fn = functools.partial(self._wrapped_func, **self._wrapped_func_kwargs)
-        return ProcessingQueue(fn, self.concurrency)
+        return ProcessingQueue(fn, self.concurrency, name=self._name)
 
     def _if_pop_check_destroyed(self, pop: bool) -> None:
         if pop: