Apply ruff/isort rules (I)

Author: DimitriPapadopoulos

continuous_integration/scripts/host_info.py

@@ -4,7 +4,6 @@
 import psutil
 
 from dask.utils import format_bytes
-
 from distributed.utils import get_ip, get_ipv6, time
 from distributed.utils_test import has_ipv6
 

distributed/__init__.py

@@ -18,7 +18,6 @@
 weakref.finalize(lambda: None, lambda: None)
 import dask
 from dask.config import config  # type: ignore
-
 from distributed.actor import Actor, ActorFuture, BaseActorFuture
 from distributed.client import (
     Client,

distributed/actor.py

@@ -11,7 +11,6 @@
 from tornado.ioloop import IOLoop
 
 from dask._task_spec import TaskRef
-
 from distributed.client import Future
 from distributed.protocol import to_serialize
 from distributed.utils import LateLoopEvent, iscoroutinefunction, sync, thread_state

distributed/batched.py

@@ -10,7 +10,6 @@
 
 import dask
 from dask.utils import parse_timedelta
-
 from distributed.core import CommClosedError
 from distributed.metrics import time
 

distributed/cfexecutor.py

@@ -7,7 +7,6 @@
 from tornado import gen
 
 from dask.utils import parse_timedelta
-
 from distributed.metrics import time
 from distributed.utils import TimeoutError, sync
 

distributed/chaos.py

@@ -7,7 +7,6 @@
 from typing import Literal
 
 from dask.utils import parse_timedelta
-
 from distributed.diagnostics.plugin import WorkerPlugin
 
 

distributed/cli/dask_worker.py

@@ -17,7 +17,6 @@
 
 import dask
 from dask.system import CPU_COUNT
-
 from distributed import Nanny
 from distributed._signals import wait_for_signals
 from distributed.comm import get_address_host_port

distributed/cli/tests/test_dask_scheduler.py

@@ -18,10 +18,9 @@
 import requests
 from click.testing import CliRunner
 
-from dask.utils import tmpfile
-
 import distributed
 import distributed.cli.dask_scheduler
+from dask.utils import tmpfile
 from distributed import Client, Scheduler
 from distributed.compatibility import LINUX, WINDOWS
 from distributed.metrics import time

distributed/cli/tests/test_dask_worker.py

@@ -12,7 +12,6 @@
 from click.testing import CliRunner
 
 from dask.utils import tmpfile
-
 from distributed import Client
 from distributed.cli.dask_worker import _apportion_ports, main
 from distributed.compatibility import LINUX, WINDOWS

distributed/client.py

@@ -51,6 +51,7 @@
 from tornado.ioloop import IOLoop
 
 import dask
+import distributed.utils
 from dask._expr import Expr, HLGExpr, LLGExpr
 from dask._task_spec import DataNode, GraphNode, List, Task, TaskRef, parse_input
 from dask.base import collections_to_expr
@@ -68,8 +69,6 @@
     typename,
 )
 from dask.widgets import get_template
-
-import distributed.utils
 from distributed import cluster_dump, preloading
 from distributed import versions as version_module
 from distributed.batched import BatchedSend