fix: prepend bot name identifier (from settings) to task names

ApeWorX · Jan 30, 2025 · 7a55e5e · 7a55e5e
1 parent 0ac1847
commit 7a55e5e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/silverback/main.py b/silverback/main.py
@@ -182,7 +182,7 @@ def __register_system_task(
         return self.broker.register_task(
             task_handler,
             # NOTE: Name makes it impossible to conflict with user's handler fn names
-            task_name=str(task_type),
+            task_name=f"{self.identifier.name}:{task_type}",
             task_type=str(task_type),
         )
 
@@ -316,7 +316,7 @@ def add_taskiq_task(
 
             return self.broker.register_task(
                 handler,
-                task_name=handler.__name__,
+                task_name=f"{self.identifier.name}:{handler.__name__}",
                 **labels,
             )
 

diff --git a/silverback/runner.py b/silverback/runner.py
@@ -52,7 +52,9 @@ def __init__(
 
     def _create_task_kicker(self, task_data: TaskData) -> AsyncKicker:
         return AsyncKicker(
-            task_name=task_data.name, broker=self.bot.broker, labels=task_data.labels
+            task_name=f"{self.bot.identifier.name}:{task_data.name}",
+            broker=self.bot.broker,
+            labels=task_data.labels,
         )
 
     def _create_system_task_kicker(self, task_type: TaskType) -> AsyncKicker: