Skip to content

Commit

Permalink
Rename flag part 3
Browse files Browse the repository at this point in the history
  • Loading branch information
lukasmittag committed Oct 14, 2024
1 parent 244ff5a commit ce689a3
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions kuksa-client/tests/test_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -1270,7 +1270,7 @@ async def test_set_some_updates_v2(
) as client:
await client.set(
updates=_updates,
v1=False,
try_v2=True,
)
assert val_servicer_v1.Get.call_count == 1
assert (
Expand Down Expand Up @@ -1338,7 +1338,7 @@ async def test_set_no_updates_provided(
"127.0.0.1", unused_tcp_port, ensure_startup_connection=False
) as client:
with pytest.raises(kuksa_client.grpc.VSSClientError) as exc_info:
await client.set(updates=[], v1=False)
await client.set(updates=[], try_v2=True)

assert (
exc_info.value.args
Expand Down Expand Up @@ -1426,7 +1426,7 @@ async def test_set_nonexistent_entries_v2(
(Field.VALUE,),
),
),
v1=False,
try_v2=True,
)

assert val_servicer_v1.Get.call_count == 1
Expand All @@ -1443,7 +1443,7 @@ async def test_set_nonexistent_entries_v2(
(Field.VALUE,),
),
),
v1=False,
try_v2=True,
)

assert (
Expand Down Expand Up @@ -1736,7 +1736,7 @@ async def test_subscribe_some_entries_v2(
),
)
),
v1=False,
try_v2=True,
):
actual_responses.append(updates)

Expand Down Expand Up @@ -1820,7 +1820,7 @@ async def test_subscribe_no_entries_requested(
"127.0.0.1", unused_tcp_port, ensure_startup_connection=False
) as client:
with pytest.raises(VSSClientError):
async for _ in client.subscribe(entries=(), v1=False):
async for _ in client.subscribe(entries=(), try_v2=True):
pass

@pytest.mark.usefixtures("val_server")
Expand Down Expand Up @@ -1855,7 +1855,7 @@ async def test_subscribe_nonexistent_entries(
),
)
),
v1=False,
try_v2=True,
):
pass

Expand Down Expand Up @@ -2048,7 +2048,7 @@ async def test_add_subscriber_v2(self, mocker, unused_tcp_port, val_servicer_v2)
entries=(
EntryRequest("Vehicle.Speed", View.CURRENT_VALUE, (Field.VALUE,)),
),
v1=False,
try_v2=True,
)
sub_uid = await subscriber_manager.add_subscriber(
subscribe_response_stream, callback=callback
Expand Down Expand Up @@ -2107,7 +2107,7 @@ async def test_remove_subscriber_v2(self, mocker, unused_tcp_port, val_servicer_
entries=(
EntryRequest("Vehicle.Speed", View.CURRENT_VALUE, (Field.VALUE,)),
),
v1=False,
try_v2=True,
)
sub_uid = await subscriber_manager.add_subscriber(
subscribe_response_stream, callback=mocker.Mock()
Expand Down

0 comments on commit ce689a3

Please sign in to comment.