From acb786d2675d32aae1b7cb0e80c8a7308315e135 Mon Sep 17 00:00:00 2001 From: Sanghun Lee Date: Thu, 17 Oct 2024 16:33:34 +0900 Subject: [PATCH] chore: fix typo in storage backend --- src/ai/backend/storage/abc.py | 4 ++-- src/ai/backend/storage/context.py | 2 +- src/ai/backend/storage/gpfs/__init__.py | 4 ++-- src/ai/backend/storage/vast/__init__.py | 4 ++-- src/ai/backend/storage/weka/__init__.py | 4 ++-- tests/storage-proxy/conftest.py | 2 +- 6 files changed, 10 insertions(+), 10 deletions(-) diff --git a/src/ai/backend/storage/abc.py b/src/ai/backend/storage/abc.py index 18b609ba5c..56b922c342 100644 --- a/src/ai/backend/storage/abc.py +++ b/src/ai/backend/storage/abc.py @@ -198,7 +198,7 @@ def __init__( mount_path: Path, *, etcd: AsyncEtcd, - event_dispathcer: EventDispatcher, + event_dispatcher: EventDispatcher, event_producer: EventProducer, options: Optional[Mapping[str, Any]] = None, ) -> None: @@ -206,7 +206,7 @@ def __init__( self.mount_path = mount_path self.config = options or {} self.etcd = etcd - self.event_dispathcer = event_dispathcer + self.event_dispatcher = event_dispatcher self.event_producer = event_producer async def init(self) -> None: diff --git a/src/ai/backend/storage/context.py b/src/ai/backend/storage/context.py index 55667d22ce..6b96f12078 100644 --- a/src/ai/backend/storage/context.py +++ b/src/ai/backend/storage/context.py @@ -195,7 +195,7 @@ async def get_volume(self, name: str) -> AsyncIterator[AbstractVolume]: mount_path=Path(volume_config["path"]), options=volume_config["options"] or {}, etcd=self.etcd, - event_dispathcer=self.event_dispatcher, + event_dispatcher=self.event_dispatcher, event_producer=self.event_producer, ) diff --git a/src/ai/backend/storage/gpfs/__init__.py b/src/ai/backend/storage/gpfs/__init__.py index 9b0950c20b..ae397e7e68 100644 --- a/src/ai/backend/storage/gpfs/__init__.py +++ b/src/ai/backend/storage/gpfs/__init__.py @@ -117,7 +117,7 @@ def __init__( mount_path: Path, *, etcd: AsyncEtcd, - event_dispathcer: EventDispatcher, + event_dispatcher: EventDispatcher, event_producer: EventProducer, options: Optional[Mapping[str, Any]] = None, ) -> None: @@ -126,7 +126,7 @@ def __init__( mount_path, etcd=etcd, options=options, - event_dispathcer=event_dispathcer, + event_dispatcher=event_dispatcher, event_producer=event_producer, ) verify_ssl = self.config.get("gpfs_verify_ssl", False) diff --git a/src/ai/backend/storage/vast/__init__.py b/src/ai/backend/storage/vast/__init__.py index 85de2c7e70..045bbb4222 100644 --- a/src/ai/backend/storage/vast/__init__.py +++ b/src/ai/backend/storage/vast/__init__.py @@ -179,7 +179,7 @@ def __init__( mount_path: Path, *, etcd: AsyncEtcd, - event_dispathcer: EventDispatcher, + event_dispatcher: EventDispatcher, event_producer: EventProducer, options: Optional[Mapping[str, Any]] = None, ) -> None: @@ -188,7 +188,7 @@ def __init__( mount_path, etcd=etcd, options=options, - event_dispathcer=event_dispathcer, + event_dispatcher=event_dispatcher, event_producer=event_producer, ) self.config = cast(Mapping[str, Any], config_iv.check(self.config)) diff --git a/src/ai/backend/storage/weka/__init__.py b/src/ai/backend/storage/weka/__init__.py index 55a041968f..c21fece36f 100644 --- a/src/ai/backend/storage/weka/__init__.py +++ b/src/ai/backend/storage/weka/__init__.py @@ -105,7 +105,7 @@ def __init__( mount_path: Path, *, etcd: AsyncEtcd, - event_dispathcer: EventDispatcher, + event_dispatcher: EventDispatcher, event_producer: EventProducer, options: Optional[Mapping[str, Any]] = None, ) -> None: @@ -114,7 +114,7 @@ def __init__( mount_path, etcd=etcd, options=options, - event_dispathcer=event_dispathcer, + event_dispatcher=event_dispatcher, event_producer=event_producer, ) ssl_verify = self.config.get("weka_verify_ssl", False) diff --git a/tests/storage-proxy/conftest.py b/tests/storage-proxy/conftest.py index a8acae6f52..4aaf833308 100644 --- a/tests/storage-proxy/conftest.py +++ b/tests/storage-proxy/conftest.py @@ -123,7 +123,7 @@ async def volume( volume_path, etcd=mock_etcd, options=backend_options, - event_dispathcer=mock_event_dispatcher, + event_dispatcher=mock_event_dispatcher, event_producer=mock_event_producer, ) await volume.init()