diff --git a/silverback/persistence.py b/silverback/persistence.py index 25ebf4fd..bc91a683 100644 --- a/silverback/persistence.py +++ b/silverback/persistence.py @@ -9,7 +9,7 @@ from taskiq import TaskiqResult from typing_extensions import Self # Introduced 3.11 -from .types import IntOrNone, ISilverbackSettings, SilverbackIdent +from .types import IntOrNone, SilverbackIdent _HandlerReturnType = TypeVar("_HandlerReturnType") @@ -53,9 +53,6 @@ def from_taskiq( class BasePersistentStorage(ABC): - def __init__(self, settings: ISilverbackSettings): - self.settings = settings - @abstractmethod async def init(self): """Handle any async initialization from Silverback settings (e.g. migrations).""" diff --git a/silverback/settings.py b/silverback/settings.py index a4a6dc7c..98fcf55c 100644 --- a/silverback/settings.py +++ b/silverback/settings.py @@ -74,7 +74,7 @@ def get_persistent_storage(self) -> Optional[BasePersistentStorage]: return None persistence_class = import_from_string(self.PERSISTENCE_CLASS) - return persistence_class(self) + return persistence_class() def get_provider_context(self) -> ProviderContextManager: return self.network_manager.parse_network_choice(self.get_network_choice())