style

rekby · rekby · commit 37e117c2acec · 2023-03-02T19:10:47.000+03:00
diff --git a/ydb/_topic_reader/topic_reader_asyncio.py b/ydb/_topic_reader/topic_reader_asyncio.py
@@ -495,7 +495,9 @@ def _on_read_response(self, message: StreamReadMessage.ReadResponse):
 
     def _on_commit_response(self, message: StreamReadMessage.CommitOffsetResponse):
         for partition_offset in message.partitions_committed_offsets:
-            session = self._partition_sessions.get(partition_offset.partition_session_id)
+            session = self._partition_sessions.get(
+                partition_offset.partition_session_id
+            )
             if session is None:
                 continue
             session.ack_notify(partition_offset.committed_offset)
