Fix k8s clients docstring

hussein-awala · Jan 26, 2024 · 36e33fa · 36e33fa
1 parent 3833fdd
commit 36e33fa
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/spark_on_k8s/k8s/async_client.py b/spark_on_k8s/k8s/async_client.py
@@ -34,7 +34,7 @@ async def client(self) -> k8s.ApiClient:
 
         Examples:
             >>> import asyncio
-            >>> from spark_on_k8s.api.kubernetes_async_client import KubernetesAsyncClientManager
+            >>> from spark_on_k8s.k8s.async_client import KubernetesAsyncClientManager
             >>> async def get_namespaces():
             >>>     async with KubernetesAsyncClientManager().client() as async_client:
             ...         api = k8s.CoreV1Api(async_client)

diff --git a/spark_on_k8s/k8s/sync_client.py b/spark_on_k8s/k8s/sync_client.py
@@ -30,7 +30,7 @@ def client(self) -> k8s.ApiClient:
         """Create a Kubernetes client in a context manager.
 
         Examples:
-            >>> from spark_on_k8s.kubernetes_client import KubernetesClientManager
+            >>> from spark_on_k8s.k8s.sync_client import KubernetesClientManager
             >>> with KubernetesClientManager().client() as client:
             ...     api = k8s.CoreV1Api(client)
             ...     namespaces = [ns.metadata.name for ns in api.list_namespace().items]