Skip to content

Commit 6009f16

Browse files
Make kubernetes API objects private (#742)
1 parent b4d9cc4 commit 6009f16

File tree

4 files changed

+3
-3
lines changed

4 files changed

+3
-3
lines changed

dask_kubernetes/operator/controller/controller.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
from importlib_metadata import entry_points
1212
from kubernetes_asyncio.client import ApiException
1313

14-
from dask_kubernetes.operator.objects import DaskCluster
14+
from dask_kubernetes.operator._objects import DaskCluster
1515
from dask_kubernetes.common.auth import ClusterAuth
1616
from dask_kubernetes.common.networking import get_scheduler_address
1717
from distributed.core import rpc, clean_exception

dask_kubernetes/operator/controller/tests/test_controller.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
KUBERNETES_DATETIME_FORMAT,
1515
get_job_runner_pod_name,
1616
)
17-
from dask_kubernetes.operator.objects import DaskCluster, DaskWorkerGroup, DaskJob
17+
from dask_kubernetes.operator._objects import DaskCluster, DaskWorkerGroup, DaskJob
1818

1919
DIR = pathlib.Path(__file__).parent.absolute()
2020

dask_kubernetes/operator/kubecluster/tests/test_kubecluster.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
from dask.distributed import Client
55
from distributed.utils import TimeoutError
66

7-
from dask_kubernetes.operator.objects import DaskCluster
7+
from dask_kubernetes.operator._objects import DaskCluster
88
from dask_kubernetes.operator import KubeCluster, make_cluster_spec
99
from dask_kubernetes.exceptions import SchedulerStartupError
1010

0 commit comments

Comments
 (0)