chore: fix typo in storage backend (#2917) (#2926)

lablup · Oct 21, 2024 · b703459 · b703459
1 parent 4cfdadb
commit b703459
Show file tree

Hide file tree

Showing 6 changed files with 10 additions and 10 deletions.
diff --git a/src/ai/backend/storage/abc.py b/src/ai/backend/storage/abc.py
@@ -198,15 +198,15 @@ def __init__(
         mount_path: Path,
         *,
         etcd: AsyncEtcd,
-        event_dispathcer: EventDispatcher,
+        event_dispatcher: EventDispatcher,
         event_producer: EventProducer,
         options: Optional[Mapping[str, Any]] = None,
     ) -> None:
         self.local_config = local_config
         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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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()