Drop Python 3.9

.github/workflows/tests.yml

@@ -14,9 +14,6 @@ jobs:
     strategy:
       matrix:
         include:
-        - os: ubuntu-latest
-          python: 3.9
-          toxenv: py39
         - os: ubuntu-latest
           python: '3.10'
           toxenv: py310

psbench/benchmarks/endpoint_qps/main.py

@@ -9,9 +9,9 @@
 import multiprocessing
 import sys
 import time
+from collections.abc import Callable
 from statistics import stdev
 from typing import Any
-from typing import Callable
 
 if sys.version_info >= (3, 11):  # pragma: >=3.11 cover
     pass

psbench/benchmarks/task_pipelining/main.py

@@ -6,10 +6,10 @@
 import queue
 import threading
 import time
+from collections.abc import Callable
 from concurrent.futures import Executor
 from concurrent.futures import Future
 from typing import Any
-from typing import Callable
 from typing import NamedTuple
 
 from parsl.concurrent import ParslPoolExecutor
@@ -296,7 +296,12 @@ def receiver() -> None:
 
     task_timestamps = [
         mid.collate(start, end)
-        for start, mid, end in zip(task_submitted, task_times, task_received)
+        for start, mid, end in zip(
+            task_submitted,
+            task_times,
+            task_received,
+            strict=True,
+        )
     ]
 
     return RunResult(

psbench/benchmarks/workflow_memory/main.py

@@ -6,11 +6,11 @@
 import logging
 import sys
 import time
+from collections.abc import Callable
 from collections.abc import Sequence
 from concurrent.futures import Executor
 from concurrent.futures import Future
 from typing import Any
-from typing import Callable
 from typing import TypeVar
 
 if sys.version_info >= (3, 11):  # pragma: >=3.11 cover

psbench/executor/dask.py

@@ -1,20 +1,15 @@
 from __future__ import annotations
 
-import sys
+from collections.abc import Callable
 from collections.abc import Generator
 from collections.abc import Iterable
 from collections.abc import Iterator
 from concurrent.futures import Executor
 from concurrent.futures import Future
 from typing import Any
-from typing import Callable
+from typing import ParamSpec
 from typing import TypeVar
 
-if sys.version_info >= (3, 10):  # pragma: >=3.10 cover
-    from typing import ParamSpec
-else:  # pragma: <3.10 cover
-    from typing_extensions import ParamSpec
-
 from dask.distributed import Client
 
 P = ParamSpec('P')

pyproject.toml

@@ -14,11 +14,10 @@ maintainers = [
 ]
 description = "ProxyStore benchmark suite."
 readme = "README.md"
-requires-python = ">=3.9"
+requires-python = ">=3.10"
 license = {file = "MIT"}
 classifiers = [
     "License :: OSI Approved :: MIT License",
-    "Programming Language :: Python :: 3.9",
     "Programming Language :: Python :: 3.10",
     "Programming Language :: Python :: 3.11",
     "Programming Language :: Python :: 3.12",
@@ -29,10 +28,8 @@ classifiers = [
 dependencies = [
     "adios2==2.10.1",
     "colmena==0.7.1",
-    "dask==2023.5.0; python_version < '3.10'",
-    "dask==2025.1.0; python_version >= '3.10'",
-    "distributed==2023.5.0; python_version < '3.10'",
-    "distributed==2025.1.0; python_version >= '3.10'",
+    "dask==2025.1.0",
+    "distributed==2025.1.0",
     "globus-compute-endpoint==3.0.*",
     "globus-compute-sdk==3.0.*",
     "proxystore[all]==0.8.*",
@@ -114,7 +111,7 @@ filterwarnings = [
 
 [tool.ruff]
 line-length = 79
-target-version = "py39"
+target-version = "py310"
 
 [tool.ruff.format]
 indent-style = "space"

testing/globus_compute.py

@@ -2,10 +2,10 @@
 
 import contextlib
 import uuid
+from collections.abc import Callable
 from collections.abc import Generator
 from concurrent.futures import Future
 from typing import Any
-from typing import Callable
 from typing import TypeVar
 from unittest import mock
 

tox.ini

@@ -1,5 +1,5 @@
 [tox]
-envlist = py39, py310, py311, py312, py313, pre-commit
+envlist = py310, py311, py312, py313, pre-commit
 
 [testenv]
 extras = dev