Apply ruff/isort rules (I)

DimitriPapadopoulos · DimitriPapadopoulos · commit e82431202092 · 2025-11-24T23:04:17.000+01:00
diff --git a/distributed/utils.py b/distributed/utils.py
@@ -46,9 +46,8 @@
 from pickle import PickleBuffer
 from time import sleep
 from types import ModuleType
-from typing import TYPE_CHECKING
+from typing import TYPE_CHECKING, ClassVar, TypeVar, overload
 from typing import Any as AnyType
-from typing import ClassVar, TypeVar, overload
 
 import psutil
 import tblib.pickling_support
@@ -67,9 +66,8 @@
 from tornado.ioloop import IOLoop
 
 import dask
-from dask.utils import _deprecated
+from dask.utils import _deprecated, key_split
 from dask.utils import ensure_bytes as _ensure_bytes
-from dask.utils import key_split
 from dask.utils import parse_timedelta as _parse_timedelta
 from dask.widgets import get_template
 
diff --git a/distributed/utils_test.py b/distributed/utils_test.py
@@ -80,9 +80,9 @@
     InvalidTransition,
     SecedeEvent,
     StateMachineEvent,
+    WorkerState,
 )
 from distributed.worker_state_machine import TaskState as WorkerTaskState
-from distributed.worker_state_machine import WorkerState
 
 try:
     import dask.array  # register config
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -75,9 +75,9 @@
     context_meter_to_server_digest,
     error_message,
     pingpong,
+    send_recv,
 )
 from distributed.core import rpc as RPCType
-from distributed.core import send_recv
 from distributed.diagnostics import nvml, rmm
 from distributed.diagnostics.plugin import WorkerPlugin, _get_plugin_name
 from distributed.diskutils import WorkSpace
