Skip to content

Commit 25bd6bb

Browse files
committed
style
remove codec.value
1 parent 76f8b70 commit 25bd6bb

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

tests/conftest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ async def topic_with_messages(driver, topic_path):
145145
writer = driver.topic_client.topic_writer(
146146
topic_path, producer_and_message_group_id="fixture-producer-id"
147147
)
148-
res = await writer.write_with_ack(
148+
await writer.write_with_ack(
149149
ydb.TopicWriterMessage(data="123".encode()),
150150
ydb.TopicWriterMessage(data="456".encode()),
151151
)

ydb/_topic_writer/topic_writer_asyncio_test.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ async def writer_and_stream(self, stream) -> WriterWithMockedStream:
5959
last_seq_no=4,
6060
session_id="123",
6161
partition_id=3,
62-
supported_codecs=[Codec.CODEC_RAW.value, Codec.CODEC_GZIP.value],
62+
supported_codecs=[Codec.CODEC_RAW, Codec.CODEC_GZIP],
6363
status=ServerStatus(StatusCode.SUCCESS, []),
6464
)
6565
)
@@ -131,7 +131,7 @@ async def test_write_a_message(self, writer_and_stream: WriterWithMockedStream):
131131

132132
expected_message = StreamWriteMessage.FromClient(
133133
StreamWriteMessage.WriteRequest(
134-
codec=Codec.CODEC_RAW.value,
134+
codec=Codec.CODEC_RAW,
135135
messages=[
136136
StreamWriteMessage.WriteRequest.MessageData(
137137
seq_no=1,

0 commit comments

Comments
 (0)