black once yet

Author: rekby

ydb/_topic_reader/topic_reader.py

@@ -255,7 +255,8 @@ def __init__(
         buffer_size_bytes: int = 50 * 1024 * 1024,
         on_commit: Callable[["Events.OnCommit"], None] = None,
         on_get_partition_start_offset: Callable[
-            ["Events.OnPartitionGetStartOffsetRequest"], "Events.OnPartitionGetStartOffsetResponse"
+            ["Events.OnPartitionGetStartOffsetRequest"],
+            "Events.OnPartitionGetStartOffsetResponse",
         ] = None,
         on_partition_session_start: Callable[["StubEvent"], None] = None,
         on_partition_session_stop: Callable[["StubEvent"], None] = None,

ydb/_topic_writer/topic_writer_asyncio.py

@@ -5,8 +5,18 @@
 from typing import Deque, AsyncIterator, Union, List, Optional, Callable
 
 import ydb
-from .topic_writer import PublicWriterSettings, WriterSettings, Writer, PublicWriteResult, PublicMessage, \
-    PublicWriterInitInfo, InternalMessage, TopicWriterStopped, TopicWriterError, messages_to_proto_requests
+from .topic_writer import (
+    PublicWriterSettings,
+    WriterSettings,
+    Writer,
+    PublicWriteResult,
+    PublicMessage,
+    PublicWriterInitInfo,
+    InternalMessage,
+    TopicWriterStopped,
+    TopicWriterError,
+    messages_to_proto_requests,
+)
 from .. import (
     _apis,
     issues,