typo while check reconnector_id and style

Author: rekby

ydb/_topic_common/test_helpers.py

@@ -54,9 +54,11 @@ async def wait_condition(
     if timeout is None:
         timeout = 1
 
+    minimal_loop_count_for_wait = 1000
+
     start = time.monotonic()
     counter = 0
-    while (time.monotonic() - start < timeout) or counter < 1000:
+    while (time.monotonic() - start < timeout) or counter < minimal_loop_count_for_wait:
         counter += 1
         if f():
             return

ydb/_topic_reader/topic_reader_asyncio.py

@@ -361,10 +361,7 @@ def commit(
     ) -> datatypes.PartitionSession.CommitAckWaiter:
         partition_session = batch._commit_get_partition_session()
 
-        if (
-            partition_session.reader_reconnector_id
-            != partition_session.reader_reconnector_id
-        ):
+        if partition_session.reader_reconnector_id != self._reader_reconnector_id:
             raise TopicReaderError("reader can commit only self-produced messages")
 
         if partition_session.reader_stream_id != self._id:
@@ -498,11 +495,8 @@ def _on_read_response(self, message: StreamReadMessage.ReadResponse):
 
     def _on_commit_response(self, message: StreamReadMessage.CommitOffsetResponse):
         for partition_offset in message.partitions_committed_offsets:
-            try:
-                session = self._partition_sessions[
-                    partition_offset.partition_session_id
-                ]
-            except KeyError:
+            session = self._partition_sessions.get(partition_offset.partition_session_id)
+            if session is None:
                 continue
             session.ack_notify(partition_offset.committed_offset)