style fixes

Author: vgvoleg

tests/topics/test_topic_writer.py

@@ -7,8 +7,6 @@
 
 import ydb.aio
 
-from ydb._topic_common.test_helpers import wait_condition
-
 
 @pytest.mark.asyncio
 class TestTopicWriterAsyncIO:

ydb/_topic_reader/topic_reader_asyncio.py

@@ -3,7 +3,6 @@
 import asyncio
 import concurrent.futures
 import gzip
-import random
 import typing
 from asyncio import Task
 from collections import OrderedDict
@@ -361,7 +360,7 @@ async def wait_messages(self):
             self._state_changed.clear()
 
     def _get_first_batch(self) -> typing.Tuple[int, datatypes.PublicBatch]:
-        first_id, batch = self._message_batches.popitem(last = False)
+        first_id, batch = self._message_batches.popitem(last=False)
         return first_id, batch
 
     def receive_batch_nowait(self):

ydb/_topic_reader/topic_reader_asyncio_test.py

@@ -1171,7 +1171,9 @@ async def test_receive_batch_nowait(self, stream, stream_reader, partition_sessi
 
         assert stream_reader._buffer_size_bytes == initial_buffer_size
 
-        assert StreamReadMessage.ReadRequest(self.default_batch_size * 2) == stream.from_client.get_nowait().client_message
+        assert (
+            StreamReadMessage.ReadRequest(self.default_batch_size * 2) == stream.from_client.get_nowait().client_message
+        )
 
         with pytest.raises(asyncio.QueueEmpty):
             stream.from_client.get_nowait()