diff --git a/a_sync/primitives/queue.py b/a_sync/primitives/queue.py index 33398b98..fc4f595a 100644 --- a/a_sync/primitives/queue.py +++ b/a_sync/primitives/queue.py @@ -796,6 +796,7 @@ def __init__( Example: >>> queue = SmartProcessingQueue(func=my_task_func, num_workers=3, name='smart_queue') """ + name = name or f"{func.__module__}.{func.__qualname__}" super().__init__(func, num_workers, return_data=True, name=name, loop=loop) self._futs = weakref.WeakValueDictionary()