better

Author: JelleZijlstra

.github/workflows/tests.yml

@@ -71,14 +71,12 @@ jobs:
       - uses: actions/checkout@v6
       - uses: actions/setup-python@v6
         with:
-          python-version: "3.15"
-          allow-prereleases: true
-          check-latest: true
+          python-version: "3.14"
       - uses: astral-sh/setup-uv@v7
         with:
           version-file: "requirements-tests.txt"
       - run: uv pip install -r requirements-tests.txt --system
-      - run: python ./tests/regr_test.py --all --verbosity QUIET --max-workers=8
+      - run: python ./tests/regr_test.py --all --verbosity QUIET
 
   pyright:
     name: "pyright: Run test cases"

tests/regr_test.py

@@ -107,13 +107,6 @@ class Verbosity(IntEnum):
         "Note that this cannot be specified if --all is also specified."
     ),
 )
-parser.add_argument(
-    "-j",
-    "--max-workers",
-    type=int,
-    default=os.cpu_count(),
-    help="Maximum number of packages or mypy subprocesses to run concurrently",
-)
 
 _PRINT_QUEUE: queue.SimpleQueue[str] = queue.SimpleQueue()
 
@@ -305,7 +298,6 @@ def concurrently_run_testcases(
     verbosity: Verbosity,
     platforms_to_test: list[str],
     versions_to_test: list[str],
-    max_workers: int | None,
 ) -> list[Result]:
     packageinfo_to_tempdir = {
         distribution_info: Path(stack.enter_context(tempfile.TemporaryDirectory())) for distribution_info in testcase_directories
@@ -356,7 +348,7 @@ def cleanup_threads(
     printer_thread = threading.Thread(target=print_queued_messages, args=(event,))
     printer_thread.start()
 
-    with concurrent.futures.ThreadPoolExecutor(max_workers=max_workers) as executor:
+    with concurrent.futures.ThreadPoolExecutor(max_workers=os.cpu_count()) as executor:
         # Each temporary directory may be used by multiple processes concurrently during the next step;
         # must make sure that they're all setup correctly before starting the next step,
         # in order to avoid race conditions
@@ -381,8 +373,6 @@ def cleanup_threads(
 
 def main() -> ReturnCode:
     args = parser.parse_args()
-    if args.max_workers is not None and args.max_workers < 1:
-        parser.error("--max-workers must be a positive integer")
 
     testcase_directories = args.packages_to_test or get_all_testcase_directories()
     verbosity = Verbosity[args.verbosity]
@@ -399,9 +389,7 @@ def main() -> ReturnCode:
     results: list[Result] | None = None
 
     with ExitStack() as stack:
-        results = concurrently_run_testcases(
-            stack, testcase_directories, verbosity, platforms_to_test, versions_to_test, args.max_workers
-        )
+        results = concurrently_run_testcases(stack, testcase_directories, verbosity, platforms_to_test, versions_to_test)
 
     assert results is not None
     if not results: