style fixes

Author: vgvoleg

ydb/_topic_reader/topic_reader_asyncio.py

@@ -361,7 +361,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()