check for duplicate actor_names in decorator

Bogdanp · Aug 6, 2024 · 931bc02 · 931bc02
1 parent 4b6ad18
commit 931bc02
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dramatiq/actor.py b/dramatiq/actor.py
@@ -64,6 +64,9 @@ def __init__(
         priority: int,
         options: Dict[str, Any],
     ) -> None:
+        if actor_name in broker.actors:
+            raise ValueError(f"An actor named {actor_name!r} is already registered.")
+
         self.logger = get_logger(fn.__module__, actor_name)
         self.fn = async_to_sync(fn) if iscoroutinefunction(fn) else fn
         self.broker = broker