fixing format

Author: slampy97

ydb/aio/coordination/stream.py

@@ -35,7 +35,6 @@ async def start_session(self, path: str, timeout_millis: int):
         self._stream.write(start_msg)
 
         try:
-            # Wait for SessionStart response
             async for resp in self._stream.from_server_grpc:
                 fs = FromServer.from_proto(resp)
                 if fs.session_started:

ydb/coordination/lock_sync.py

@@ -84,26 +84,18 @@ def update(self, new_data: bytes, timeout: Optional[float] = None):
         return self._caller.safe_call_with_result(self._async_lock.update(new_data), t)
 
     def close(self, timeout: Optional[float] = None):
-        """
-        Закрытие синхронной обёртки: постараемся аккуратно освободить lock и остановить
-        фоновые ресурсы асинхронной части (stream/reconnector) через async close().
-        """
         if self._closed:
             return
         t = timeout or self._timeout_sec
 
-        # best-effort release
         try:
             self._caller.safe_call_with_result(self._async_lock.release(), t)
         except Exception:
             pass
 
-        # если асинхнронный объект предоставляет close(flush) — вызвать его, иначе игнорировать
         try:
-            # используем lambda, чтобы получить coroutine
             self._caller.safe_call_with_result(self._async_lock.close(True), t)
         except Exception:
-            # некоторые версии могут не иметь close или оно может упасть — игнорируем
             pass
 
         self._closed = True