Remove obsolete comment

Co-authored-by: Jacob Tomlinson <[email protected]>

Author: DimitriPapadopoulos

distributed/active_memory_manager.py

@@ -436,7 +436,6 @@ class Suggestion(NamedTuple):
 
 
 if TYPE_CHECKING:
-    # TODO import from typing (requires Python >=3.10)
     from typing import TypeAlias
 
 SuggestionGenerator: TypeAlias = Generator[

distributed/protocol/compression.py

@@ -22,7 +22,6 @@
 from distributed.utils import ensure_memoryview, nbytes
 
 if TYPE_CHECKING:
-    # TODO import from typing (requires Python >=3.10)
     from typing import TypeAlias
 
 # TODO remove quotes (requires Python >=3.10)

distributed/scheduler.py

@@ -146,10 +146,9 @@
 from distributed.variable import VariableExtension
 
 if TYPE_CHECKING:
-    # TODO import from typing (requires Python >=3.10)
-    # TODO import from typing (requires Python >=3.11)
     from typing import TypeAlias, TypeVar
 
+    # TODO import from typing (requires Python >=3.11)
     from typing_extensions import Self
 
     from dask._expr import Expr

distributed/shuffle/_core.py

@@ -48,7 +48,6 @@
 from distributed.utils_comm import retry
 
 if TYPE_CHECKING:
-    # TODO import from typing (requires Python >=3.10)
     from typing import TypeAlias
 
     from typing_extensions import ParamSpec

distributed/shuffle/_merge.py

@@ -10,7 +10,6 @@
 from distributed.shuffle._shuffle import shuffle_transfer
 
 if TYPE_CHECKING:
-    # TODO import from typing (requires Python >=3.10)
     from typing import TypeAlias
 
     import pandas as pd

distributed/shuffle/_shuffle.py

@@ -41,7 +41,6 @@
 
 logger = logging.getLogger("distributed.shuffle")
 if TYPE_CHECKING:
-    # TODO import from typing (requires Python >=3.10)
     from typing import TypeAlias
 
     import pandas as pd

distributed/shuffle/_worker_plugin.py

@@ -20,7 +20,6 @@
 from distributed.utils import log_errors, sync
 
 if TYPE_CHECKING:
-    # TODO import from typing (requires Python >=3.10)
     import pandas as pd
 
     from distributed.worker import Worker

distributed/worker_memory.py

@@ -47,7 +47,6 @@
 from distributed.utils import RateLimiterFilter, has_arg, log_errors
 
 if TYPE_CHECKING:
-    # TODO import from typing (requires Python >=3.10)
     from typing import TypeAlias
 
     # Circular imports

distributed/worker_state_machine.py

@@ -47,11 +47,10 @@
 logger = logging.getLogger("distributed.worker.state_machine")
 
 if TYPE_CHECKING:
-    # TODO import from typing (ParamSpec and TypeAlias requires Python >=3.10)
-    # TODO import from typing (NotRequired requires Python >=3.11)
-    from typing import TypeAlias
+    from typing import ParamSpec, TypeAlias
 
-    from typing_extensions import NotRequired, ParamSpec
+    # TODO import from typing (NotRequired requires Python >=3.11)
+    from typing_extensions import NotRequired
 
     P = ParamSpec("P")