Skip to content

Commit 48d1b36

Browse files
committed
fix linter
1 parent be267ce commit 48d1b36

File tree

2 files changed

+18
-12
lines changed

2 files changed

+18
-12
lines changed

examples/topic/writer_async_example.py

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -43,9 +43,9 @@ async def send_messages(writer: ydb.TopicWriterAsyncIO):
4343
# full forms
4444
await writer.write(ydb.TopicWriterMessage("mess")) # send text
4545
await writer.write(ydb.TopicWriterMessage(bytes([1, 2, 3]))) # send bytes
46-
await writer.write([
47-
ydb.TopicWriterMessage("mess-1"), ydb.TopicWriterMessage("mess-2")
48-
]) # send few messages by one call
46+
await writer.write(
47+
[ydb.TopicWriterMessage("mess-1"), ydb.TopicWriterMessage("mess-2")]
48+
) # send few messages by one call
4949

5050
# with meta
5151
await writer.write(
@@ -71,9 +71,12 @@ async def send_messages_with_manual_seqno(writer: ydb.TopicWriter):
7171

7272
async def send_messages_with_wait_ack(writer: ydb.TopicWriterAsyncIO):
7373
# future wait
74-
await writer.write_with_result([
75-
ydb.TopicWriterMessage("mess", seqno=1), ydb.TopicWriterMessage("mess", seqno=2)
76-
])
74+
await writer.write_with_result(
75+
[
76+
ydb.TopicWriterMessage("mess", seqno=1),
77+
ydb.TopicWriterMessage("mess", seqno=2),
78+
]
79+
)
7780

7881
# send with flush
7982
await writer.write(["1", "2", "3"])

examples/topic/writer_example.py

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -56,9 +56,9 @@ def send_messages(writer: ydb.TopicWriter):
5656
# full forms
5757
writer.write(ydb.TopicWriterMessage("mess")) # send text
5858
writer.write(ydb.TopicWriterMessage(bytes([1, 2, 3]))) # send bytes
59-
writer.write([
60-
ydb.TopicWriterMessage("mess-1"), ydb.TopicWriterMessage("mess-2")
61-
]) # send few messages by one call
59+
writer.write(
60+
[ydb.TopicWriterMessage("mess-1"), ydb.TopicWriterMessage("mess-2")]
61+
) # send few messages by one call
6262

6363
# with meta
6464
writer.write(ydb.TopicWriterMessage("asd", seqno=123, created_at_ns=time.time_ns()))
@@ -87,9 +87,12 @@ def send_messages_with_wait_ack(writer: ydb.TopicWriter):
8787
).result()
8888

8989
# implicit, by sync call
90-
writer.write_with_ack([
91-
ydb.TopicWriterMessage("mess", seqno=1), ydb.TopicWriterMessage("mess", seqno=2)
92-
])
90+
writer.write_with_ack(
91+
[
92+
ydb.TopicWriterMessage("mess", seqno=1),
93+
ydb.TopicWriterMessage("mess", seqno=2),
94+
]
95+
)
9396
# write_with_ack
9497

9598
# send with flush

0 commit comments

Comments
 (0)