WIP

Author: athornton

.github/workflows/ci.yaml

@@ -4,7 +4,7 @@ env:
   # Current supported uv version. The uv documentation recommends pinning
   # this. The version should match the version used in .pre-commit-config.yaml
   # and frozen in uv.lock. It is updated by make update-deps.
-  UV_VERSION: "0.10.10"
+  UV_VERSION: "0.10.11"
 
 "on":
   merge_group: {}

.github/workflows/periodic-ci.yaml

@@ -9,7 +9,7 @@ env:
   # Current supported uv version. The uv documentation recommends pinning
   # this. The version should match the version used in .pre-commit-config.yaml
   # and frozen in uv.lock. It is updated by make update-deps.
-  UV_VERSION: "0.10.10"
+  UV_VERSION: "0.10.11"
 
 "on":
   schedule:

.pre-commit-config.yaml

@@ -21,6 +21,6 @@ repos:
         args: [-l, '79']
 
   - repo: https://github.com/astral-sh/uv-pre-commit
-    rev: 0.10.10
+    rev: 0.10.11
     hooks:
       - id: uv-lock

pyproject.toml

@@ -20,6 +20,7 @@ classifiers = [
 ]
 requires-python = ">=3.13"
 dependencies = [
+    "anyio >= 4.12.1",
     "httpx[http2]>=0.27",
 ]
 dynamic = ["version"]
@@ -36,6 +37,7 @@ build-backend = "setuptools.build_meta"
 
 [dependency-groups]
 dev = [
+    "pyfakefs",
     "pytest",
     "pytest-asyncio",
     "pytest-cov",

src/parallel_http_client/_cli.py

@@ -48,6 +48,12 @@ def _parse_args() -> argparse.Namespace:
         type=int,
         help=("Chunk size to read per HTTP request [default: 1048576]"),
     )
+    parser.add_argument(
+        "-b",
+        "--benchmark",
+        action="store_true",
+        help=("Report download speed when finished [default: False]"),
+    )
     parser.add_argument(
         "-r",
         "--report",
@@ -82,7 +88,7 @@ def _xform_args(args: argparse.Namespace) -> argparse.Namespace:
     if isinstance(args.url, str):
         args.url = httpx.URL(args.url)
     if args.output is None:
-        args.output = Path(str(args.url)).name
+        args.output = Path.cwd().resolve() / Path(str(args.url)).name
     else:
         args.output = Path(args.output)
     if args.working_dir is not None:
@@ -104,6 +110,7 @@ def parallel_fetch() -> None:
         max_threads=args.threads,
         max_procs=args.processes,
         chunk_size=args.chunksize,
+        benchmark=args.benchmark,
         report=args.report,
         debug=args.debug,
         byte_range=args.byte_range,