Make topics a set

goodboy · Oct 7, 2020 · 36ec668 · 36ec668
1 parent 2af1e26
commit 36ec668
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/tractor/msg.py b/tractor/msg.py
@@ -193,7 +193,7 @@ async def _execute(
             topics: Set[str],
             *args,
             # *,
-            task_name: str = None,
+            task_name: str = None,  # default: only one task allocated
             packetizer: Callable = None,
             **kwargs,
         ):
@@ -202,6 +202,7 @@ async def _execute(
                     f"{agen} must be called with a `task_name` named "
                     f"argument with a falue from {tasks}")
 
+            topics = set(topics)
             ss = current_actor().statespace
             lockmap = ss.setdefault('_pubtask2lock', task2lock)
             lock = lockmap[task_name]