A tiny, dependency-free HTTP client for Python with cancellable in-flight requests and hard wall-clock timeout.
Project description
cancellable_http_client
A tiny, dependency-free HTTP client for Python with cancellable in-flight requests and hard wall-clock timeout.
- Standard library only — no
requests, nohttpx, nourllib3. - Single file, ~350 lines (~180 lines of code).
- Synchronous API that plays well with
threading-based workers. - Safe
close()from any thread, at any time, including mid-transfer. - Hard wall-clock
timeoutthat bounds the entire request.
Installation
pip install cancellable-http-client
PyPI: https://pypi.org/project/cancellable-http-client/
Why it exists
Python has no clean way to interrupt a thread that is blocked on a socket read. concurrent.futures.Future.cancel() does nothing once the task has started, and requests / urllib.urlopen() give you no handle to abort an in-flight request.
The one primitive that does work is closing the underlying socket: any pending recv() immediately unblocks with an error. This module wraps that trick behind a tiny, boring API so you don't have to reinvent it — or worry about the lifecycle edge cases — every time you need it.
If your codebase is built around asyncio, you don't need this; use httpx and task.cancel() instead. This module targets the very real case where you have existing threaded code and you want one HTTP call in the middle of it to be cancellable, without rewriting everything to be async.
Usage
import time
import cancellable_http_client as client
req = client.Request("https://example.com/")
req.start() # the actual TCP connection happens here
start = time.monotonic()
while not req.done:
if time.monotonic() - start > 5:
print("taking too long, aborting...")
req.close() # interrupts the request if it's still in-flight
req.wait(0.1) # wait a bit before checking again
if req.error:
print(f"failed: {req.error}")
elif req.response and req.response.status == 200:
print(req.response.body)
req.close() # safe to call any time, even mid-flight
You can also use it as a context manager:
with client.Request("https://example.com/") as req:
req.start()
req.wait(timeout=5)
...
# close() is called automatically on exit
Sharing a thread pool
By default each Request spawns its own daemon thread. To reuse a pool instead, assign an Executor to the module-level attribute:
from concurrent.futures import ThreadPoolExecutor
client.executor = ThreadPoolExecutor(max_workers=8)
API
Request(url, method="GET", headers=None, body=b"", socket_timeout=30, timeout=None, max_response_size=5*1024*1024)
Construct a request. No network I/O happens here — connection failures are reported via error after start().
socket_timeout— per-socket-operation timeout in seconds, passed tohttp.client.HTTPConnection. Must be a positive number —Noneor0may cause the worker thread to block indefinitely.timeout— wall-clock limit in seconds for the entire request. Triggersclose()automatically if the request is not done in time.Nonedisables.max_response_size— maximum response body size in bytes. If the body exceeds this limit, the request fails withResponseTooLargeError. Defaults to 5 MB. Set toNoneor0for unlimited.start()— kick off the request. Non-blocking.wait(timeout=None) -> bool— block until the request finishes. ReturnsTrueon completion,Falseon timeout.close()— abort the request and release resources. Safe to call any time, from any thread, any number of times.done(property) —Trueonce the request has finished (success, failure, or close).response— aResponseobject on success, otherwiseNone.error— the exception raised during the request, orNone.
ResponseTooLargeError
Raised when the response body exceeds max_response_size. Available as cancellable_http_client.ResponseTooLargeError.
Response
A read-only, socket-free container exposing the same attributes as http.client.HTTPResponse:
status,reason,versionheaders(anhttp.client.HTTPMessage)body(bytearray, eagerly read)getheader(name, default=None),getheaders()
Defaults
| Parameter | Scope | Default |
|---|---|---|
socket_timeout |
Per socket operation (connect, send, recv) | 30 s |
timeout |
Wall-clock limit on the entire request | None (no limit) |
max_response_size |
Maximum response body size | 5 MB |
Robust timeout
Most Python HTTP clients set a per-socket-operation timeout (socket.settimeout). This leaves several gaps:
- Slow drip — a server that sends one byte every 29 seconds never triggers a 30-second socket timeout, yet the total transfer can take arbitrarily long.
- DNS resolution —
socket.getaddrinfo()is a blocking C library call with no timeout parameter. Python cannot interrupt it. - Total elapsed time — there is no built-in way to cap the wall-clock time of an entire request across connection, TLS handshake, sending, and receiving.
The timeout parameter addresses this. When it fires it calls close(), which immediately unblocks any pending socket operation by closing the underlying connection. This gives you a hard upper bound on how long wait() will block — something that socket_timeout alone cannot guarantee.
Note: timeout is disabled by default (None). Set it explicitly when you need a wall-clock guarantee.
Comparison with existing libraries
| cancellable_http_client | httpx | requests | |
|---|---|---|---|
| Cancel an in-flight request from another thread | ✅ | ⚠️ async, unreliable | ⚠️ hacky |
| Hard wall-clock timeout on entire request | ✅ | ⚠️ per-operation | ⚠️ per-operation |
| Synchronous API | ✅ | ✅ (also async) | ✅ |
| No third-party dependencies | ✅ | ❌ | ❌ |
| Line count | ~350 (~180 code) | thousands | thousands |
| Fits a threading-based worker | ✅ | ❌ | ⚠️ |
| Redirects, cookies, User-Agent | ⚠️ manual | ✅ | ✅ |
httpx is a good choice if you are already in an asyncio world, though task.cancel() on in-flight requests can leave the connection pool in a broken state. requests does not offer a reliable way to interrupt an in-flight call; Session.close() does not forcibly close active sockets (psf/requests#5633).
Limitations
This library is a thin wrapper around http.client and does not provide the high-level conveniences found in requests or httpx:
- No automatic redirect following
- No cookie management
- No default User-Agent header
- No HTTP/2 support
These are all http.client limitations, not restrictions added by this library. You can still handle them manually via the headers parameter.
Tests
python -m unittest discover -s tests -v
No third-party test dependencies. Tests use local throwaway servers (normal, slow, blackhole, mid-body disconnect) to exercise cancellation, timeout, and error paths without touching the network.
License
Copyright 2026 Sakilabo Corporation Ltd. Licensed under the Universal Permissive License v 1.0 (UPL-1.0).
References (for the eventual public release)
Background reading and related work collected during the design of this module. Useful as citations in the README or a launch blog post.
Prior art / closest existing work
-
"TIL: Stopping Requests Mid Flight" — haykot.dev A blog post describing the "close the socket from another thread" trick as a personal discovery. The same underlying idea as this module, but kept as a snippet rather than packaged as a library.
-
httpcore on PyPI the low-level HTTP engine behind
httpx. Supports cancellation via async task cancellation; relies onasyncioortrio. -
HTTPX modern high-level HTTP client; cancellation is done via
task.cancel()in an async context. -
asyncio-cancel-token a cancellation-token utility for
asyncio-based code.
The underlying Python pain points
-
Graceful exit from ThreadPoolExecutor when blocked on IO — discuss.python.org Ongoing discussion acknowledging that Python has no clean way to cancel a worker that is blocked on I/O. This module is effectively a targeted workaround for the HTTP-specific case.
-
threading— Python docsThreadhas nocancel()/interrupt(); cooperation viaEventis the only sanctioned approach. -
Session.close()does not close underlying sockets — psf/requests#5633 Illustrates why "just userequestsand close the session" is not a reliable answer. -
Unclosed socket in urllib when ftp request times out after connect — cpython#140691 A related stdlib lifecycle bug — background for why we deliberately take full control of the connection object.
Related stdlib primitives this module builds on
http.client— Python docs the low-level HTTP protocol implementation we wrap.threading.Event— Python docs used internally to signal completion.
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file cancellable_http_client-1.2.3.tar.gz.
File metadata
- Download URL: cancellable_http_client-1.2.3.tar.gz
- Upload date:
- Size: 14.0 kB
- Tags: Source
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.13.12
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
daca6dc64abde2f01c4219499eb28c869c8b35b209fd178887ea8e4b96ca6b35
|
|
| MD5 |
8672ad5e001dee1c48dc7de7a4f14c9f
|
|
| BLAKE2b-256 |
4b5734e7da5f77246ce4eed7040300f483a1acb230e11f8beb1563d80825337c
|
Provenance
The following attestation bundles were made for cancellable_http_client-1.2.3.tar.gz:
Publisher:
publish.yml on sakilabo/cancellable-http-client-python
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
cancellable_http_client-1.2.3.tar.gz -
Subject digest:
daca6dc64abde2f01c4219499eb28c869c8b35b209fd178887ea8e4b96ca6b35 - Sigstore transparency entry: 1786822850
- Sigstore integration time:
-
Permalink:
sakilabo/cancellable-http-client-python@30967703b72c1738732e7f19d38fd835d2ec96a1 -
Branch / Tag:
refs/tags/v1.2.3 - Owner: https://github.com/sakilabo
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
publish.yml@30967703b72c1738732e7f19d38fd835d2ec96a1 -
Trigger Event:
push
-
Statement type:
File details
Details for the file cancellable_http_client-1.2.3-py3-none-any.whl.
File metadata
- Download URL: cancellable_http_client-1.2.3-py3-none-any.whl
- Upload date:
- Size: 10.6 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? Yes
- Uploaded via: twine/6.1.0 CPython/3.13.12
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
d34c93b44c5e740d4da0b67ff7e791b80c16208a8f688a275283a3f78a616fa8
|
|
| MD5 |
70166be600a26860c0cc2457cfbb0fa7
|
|
| BLAKE2b-256 |
fa490ed943ad5ed63f5159035a8bb72588ddd04b3ce24bbc4a3c8ccb4af322a5
|
Provenance
The following attestation bundles were made for cancellable_http_client-1.2.3-py3-none-any.whl:
Publisher:
publish.yml on sakilabo/cancellable-http-client-python
-
Statement:
-
Statement type:
https://in-toto.io/Statement/v1 -
Predicate type:
https://docs.pypi.org/attestations/publish/v1 -
Subject name:
cancellable_http_client-1.2.3-py3-none-any.whl -
Subject digest:
d34c93b44c5e740d4da0b67ff7e791b80c16208a8f688a275283a3f78a616fa8 - Sigstore transparency entry: 1786822886
- Sigstore integration time:
-
Permalink:
sakilabo/cancellable-http-client-python@30967703b72c1738732e7f19d38fd835d2ec96a1 -
Branch / Tag:
refs/tags/v1.2.3 - Owner: https://github.com/sakilabo
-
Access:
public
-
Token Issuer:
https://token.actions.githubusercontent.com -
Runner Environment:
github-hosted -
Publication workflow:
publish.yml@30967703b72c1738732e7f19d38fd835d2ec96a1 -
Trigger Event:
push
-
Statement type: