Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

replace pytest-asyncio and pytest-trio with anyio #2512

Merged
merged 7 commits into from
Jan 2, 2023
Merged

replace pytest-asyncio and pytest-trio with anyio #2512

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
7b82bd4
replace pytest-asyncio with anyio
graingert Dec 20, 2022
f6ec060
remove pytest-trio also
graingert Dec 20, 2022
a56fe36
Update setup.cfg
graingert Dec 20, 2022
3794d34
use anyio.Lock in test_auth
graingert Dec 20, 2022
4d6e81d
Merge branch 'master' into remove-pytest-asyncio
tomchristie Dec 29, 2022
6082560
Merge branch 'master' into remove-pytest-asyncio
tomchristie Dec 31, 2022
8976603
Merge branch 'master' into remove-pytest-asyncio
tomchristie Jan 2, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 0 additions & 1 deletion requirements.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@ isort==5.10.1
mypy==0.982
types-certifi==2021.10.8.2
pytest==7.2.0
pytest-asyncio==0.20.3
pytest-trio==0.7.0
trio==0.21.0
trio-typing==0.7.0
Expand Down
1 change: 0 additions & 1 deletion setup.cfg
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@ combine_as_imports = True
addopts = -rxXs
filterwarnings =
error
asyncio_mode = strict
markers =
copied_from(source, changes=None): mark test as copied from somewhere else, along with a description of changes made to accodomate e.g. our test setup
network: marks tests which require network connection. Used in 3rd-party build environments that have network disabled.
Expand Down
48 changes: 24 additions & 24 deletions tests/client/test_async_client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
import httpx


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_get(server):
url = server.url
async with httpx.AsyncClient(http2=True) as client:
Expand All @@ -27,14 +27,14 @@ async def test_get(server):
pytest.param("http://", id="no-host"),
],
)
@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_get_invalid_url(server, url):
async with httpx.AsyncClient() as client:
with pytest.raises((httpx.UnsupportedProtocol, httpx.LocalProtocolError)):
await client.get(url)


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_build_request(server):
url = server.url.copy_with(path="/echo_headers")
headers = {"Custom-header": "value"}
Expand All @@ -49,23 +49,23 @@ async def test_build_request(server):
assert response.json()["Custom-header"] == "value"


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_post(server):
url = server.url
async with httpx.AsyncClient() as client:
response = await client.post(url, content=b"Hello, world!")
assert response.status_code == 200


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_post_json(server):
url = server.url
async with httpx.AsyncClient() as client:
response = await client.post(url, json={"text": "Hello, world!"})
assert response.status_code == 200


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_stream_response(server):
async with httpx.AsyncClient() as client:
async with client.stream("GET", server.url) as response:
Expand All @@ -76,7 +76,7 @@ async def test_stream_response(server):
assert response.content == b"Hello, world!"


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_access_content_stream_response(server):
async with httpx.AsyncClient() as client:
async with client.stream("GET", server.url) as response:
Expand All @@ -87,7 +87,7 @@ async def test_access_content_stream_response(server):
response.content


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_stream_request(server):
async def hello_world() -> typing.AsyncIterator[bytes]:
yield b"Hello, "
Expand All @@ -98,7 +98,7 @@ async def hello_world() -> typing.AsyncIterator[bytes]:
assert response.status_code == 200


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_cannot_stream_sync_request(server):
def hello_world() -> typing.Iterator[bytes]: # pragma: no cover
yield b"Hello, "
Expand All @@ -109,7 +109,7 @@ def hello_world() -> typing.Iterator[bytes]: # pragma: no cover
await client.post(server.url, content=hello_world())


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_raise_for_status(server):
async with httpx.AsyncClient() as client:
for status_code in (200, 400, 404, 500, 505):
Expand All @@ -125,45 +125,45 @@ async def test_raise_for_status(server):
assert response.raise_for_status() is None # type: ignore


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_options(server):
async with httpx.AsyncClient() as client:
response = await client.options(server.url)
assert response.status_code == 200
assert response.text == "Hello, world!"


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_head(server):
async with httpx.AsyncClient() as client:
response = await client.head(server.url)
assert response.status_code == 200
assert response.text == ""


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_put(server):
async with httpx.AsyncClient() as client:
response = await client.put(server.url, content=b"Hello, world!")
assert response.status_code == 200


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_patch(server):
async with httpx.AsyncClient() as client:
response = await client.patch(server.url, content=b"Hello, world!")
assert response.status_code == 200


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_delete(server):
async with httpx.AsyncClient() as client:
response = await client.delete(server.url)
assert response.status_code == 200
assert response.text == "Hello, world!"


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_100_continue(server):
headers = {"Expect": "100-continue"}
content = b"Echo request body"
Expand All @@ -177,7 +177,7 @@ async def test_100_continue(server):
assert response.content == content


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_context_managed_transport():
class Transport(httpx.AsyncBaseTransport):
def __init__(self) -> None:
Expand Down Expand Up @@ -209,7 +209,7 @@ async def __aexit__(self, *args):
]


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_context_managed_transport_and_mount():
class Transport(httpx.AsyncBaseTransport):
def __init__(self, name: str):
Expand Down Expand Up @@ -254,7 +254,7 @@ def hello_world(request):
return httpx.Response(200, text="Hello, world!")


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_client_closed_state_using_implicit_open():
client = httpx.AsyncClient(transport=httpx.MockTransport(hello_world))

Expand All @@ -275,7 +275,7 @@ async def test_client_closed_state_using_implicit_open():
pass # pragma: no cover


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_client_closed_state_using_with_block():
async with httpx.AsyncClient(transport=httpx.MockTransport(hello_world)) as client:
assert not client.is_closed
Expand All @@ -296,7 +296,7 @@ def mounted(request: httpx.Request) -> httpx.Response:
return httpx.Response(200, json=data)


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_mounted_transport():
transport = httpx.MockTransport(unmounted)
mounts = {"custom://": httpx.MockTransport(mounted)}
Expand All @@ -311,7 +311,7 @@ async def test_mounted_transport():
assert response.json() == {"app": "mounted"}


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_async_mock_transport():
async def hello_world(request):
return httpx.Response(200, text="Hello, world!")
Expand All @@ -324,7 +324,7 @@ async def hello_world(request):
assert response.text == "Hello, world!"


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_cancellation_during_stream():
"""
If any BaseException is raised during streaming the response, then the
Expand Down Expand Up @@ -364,7 +364,7 @@ async def aclose(self) -> None:
assert stream_was_closed


@pytest.mark.usefixtures("async_environment")
@pytest.mark.anyio
async def test_server_extensions(server):
url = server.url
async with httpx.AsyncClient(http2=True) as client:
Expand Down
Loading