fix(Runner): improper use of exception, created a new one (#258)

Author: fubuloubu

silverback/exceptions.py

@@ -15,6 +15,10 @@ def __init__(self, container: Any):
         super().__init__(f"Invalid container type: {container.__class__}")
 
 
+class InvalidContainerConfigurationError(Exception):
+    pass
+
+
 class UnregisteredTask(Exception):
     def __init__(self, task_name: str):
         super().__init__(f"Could not find task '{task_name}'.")

silverback/main.py

@@ -20,7 +20,12 @@
 from pydantic import BaseModel
 from taskiq import AsyncTaskiqDecoratedTask, TaskiqEvents
 
-from .exceptions import ContainerTypeMismatchError, InvalidContainerTypeError, NoSignerLoaded
+from .exceptions import (
+    ContainerTypeMismatchError,
+    InvalidContainerConfigurationError,
+    InvalidContainerTypeError,
+    NoSignerLoaded,
+)
 from .settings import Settings
 from .state import StateSnapshot
 from .types import ScalarType, SilverbackID, TaskType
@@ -402,6 +407,8 @@ def broker_task_decorator(
             :class:`~silverback.exceptions.ContainerTypeMismatchError`:
                 If there is a mismatch between `task_type` and the `container`
                 type it should handle.
+            :class:`~silverback.exceptions.ContainerConfigurationError`:
+                If there is an issue with the arguments provided.
         """
         if (
             (task_type is TaskType.NEW_BLOCK and not isinstance(container, BlockContainer))
@@ -422,9 +429,10 @@ def broker_task_decorator(
 
         elif isinstance(container, ContractEventWrapper):
             if len(container.events) != 1:
-                raise InvalidContainerTypeError(
+                raise InvalidContainerConfigurationError(
                     f"Requires exactly 1 event to unwrap: {container.events}"
                 )
+
             container = container.events[0]
 
         # Register user function as task handler with our broker
@@ -466,7 +474,7 @@ def add_taskiq_task(
                             # NOTE: Will clean up extra Nones in `encode_topics_to_string`
 
                     if unmatched_args := "', '".join(filter_args):
-                        raise InvalidContainerTypeError(
+                        raise InvalidContainerConfigurationError(
                             f"Args are not available for filtering: '{unmatched_args}'."
                         )
 
@@ -479,7 +487,7 @@ def add_taskiq_task(
                 if not cron_schedule or not pycron.has_been(
                     cron_schedule, datetime.now() - timedelta(days=366)
                 ):
-                    raise InvalidContainerTypeError(
+                    raise InvalidContainerConfigurationError(
                         f"'{cron_schedule}' is not a valid cron schedule"
                     )