Update ruff and run ruff format
This commit is contained in:
committed by
Arun Babu Neelicattu
parent
dbc612c7f3
commit
6a65ca94bc
@@ -26,12 +26,12 @@ async def _test_client(client: ThingServiceClient, name="clean room", **kwargs):
|
||||
|
||||
def _assert_request_meta_received(deadline, metadata):
|
||||
def server_side_test(stream):
|
||||
assert stream.deadline._timestamp == pytest.approx(
|
||||
deadline._timestamp, 1
|
||||
), "The provided deadline should be received serverside"
|
||||
assert (
|
||||
stream.metadata["authorization"] == metadata["authorization"]
|
||||
), "The provided authorization metadata should be received serverside"
|
||||
assert stream.deadline._timestamp == pytest.approx(deadline._timestamp, 1), (
|
||||
"The provided deadline should be received serverside"
|
||||
)
|
||||
assert stream.metadata["authorization"] == metadata["authorization"], (
|
||||
"The provided authorization metadata should be received serverside"
|
||||
)
|
||||
|
||||
return server_side_test
|
||||
|
||||
@@ -265,9 +265,9 @@ async def test_async_gen_for_stream_stream_request():
|
||||
else:
|
||||
# No more things to send make sure channel is closed
|
||||
request_chan.close()
|
||||
assert response_index == len(
|
||||
expected_things
|
||||
), "Didn't receive all expected responses"
|
||||
assert response_index == len(expected_things), (
|
||||
"Didn't receive all expected responses"
|
||||
)
|
||||
|
||||
|
||||
@pytest.mark.asyncio
|
||||
|
||||
Reference in New Issue
Block a user