Small improvements

ydb/_topic_common/common.py

@@ -100,7 +100,7 @@ def unsafe_call_with_result(self, coro: typing.Coroutine, timeout: TimeoutType):
 
     def safe_call_with_result(self, coro: typing.Coroutine, timeout: TimeoutType):
         """
-        no lost returned value from coro, but may be slower especially timeout latency - it wait coroutine cancelation.
+        no lost returned value from coro, but may be slower especially timeout latency - it wait coroutine cancellation.
         """
 
         if timeout is not None and timeout <= 0:
@@ -125,7 +125,7 @@ async def call_coro():
 
     def _safe_call_fast(self, coro: typing.Coroutine) -> typing.Any:
         """
-        no lost returned value from coro, but may be slower especially timeout latency - it wait coroutine cancelation.
+        no lost returned value from coro, but may be slower especially timeout latency - it wait coroutine cancellation.
         Wait coroutine result only one loop.
         """
         res: concurrent.futures.Future[typing.Any] = concurrent.futures.Future()

ydb/_topic_writer/topic_writer_asyncio.py

@@ -109,7 +109,7 @@ async def write_with_ack(
         messages: Union[Message, List[Message]],
     ) -> Union[PublicWriteResultTypes, List[PublicWriteResultTypes]]:
         """
-        IT IS SLOWLY WAY. IT IS BAD CHOISE IN MOST CASES.
+        IT IS SLOWLY WAY. IT IS BAD CHOICE IN MOST CASES.
         It is recommended to use write with optionally flush or write_with_ack_futures and receive acks by wait futures.
 
         send one or number of messages to server and wait acks.

ydb/convert.py

@@ -412,7 +412,7 @@ def _extend(self, other):
     @classmethod
     def from_message(cls, message, table_client_settings=None, snapshot=None, index=None):
         rows = []
-        # prepare column parsers before actuall parsing
+        # prepare column parsers before actually parsing
         column_parsers = []
         if len(message.rows) > 0:
             for column in message.columns:

ydb/driver.py

@@ -312,7 +312,7 @@ def __init__(
         :param connection_string: A string in the following format: <protocol>://<hostame>:<port>/?database=/path/to/the/database
         :param endpoint: An endpoint specified in the following format: <protocol>://<hostame>:<port>
         :param database: A database path
-        :param credentials: A credentials. If not specifed credentials constructed by default.
+        :param credentials: A credentials. If not specified credentials constructed by default.
         """
         from . import topic  # local import for prevent cycle import error
         from . import coordination  # local import for prevent cycle import error

ydb/retries.py

@@ -200,7 +200,7 @@ async def retry_operation_async(  # pylint: disable=W1113
     :param args: A tuple with positional arguments to be passed into the coroutine.
     :param kwargs: A dictionary with keyword arguments to be passed into the coroutine.
 
-    Returns awaitable result of coroutine. If retries are not succussful exception is raised.
+    Returns awaitable result of coroutine. If retries are not successful exception is raised.
     """
     backoff_ms: Optional[int] = None
 

ydb/scheme.py

@@ -446,7 +446,7 @@ def _wrap_scheme_entry(entry_pb, scheme_entry_cls=None, *args, **kwargs):
     by default that is generic SchemeEntry)
     :param args: A list of optional arguments
     :param kwargs: A dictionary of with optional arguments
-    :return: A native Python reprensentation of scheme entry
+    :return: A native Python representation of scheme entry
     """
     scheme_entry_cls = SchemeEntry if scheme_entry_cls is None else scheme_entry_cls
     return scheme_entry_cls(

ydb/table.py

@@ -1101,7 +1101,7 @@ def prepare(self, query, settings=None):
     @abstractmethod
     def explain(self, yql_text, settings=None):
         """
-        Expiremental API.
+        Experimental API.
 
         :param yql_text:
         :param settings:
@@ -1322,7 +1322,7 @@ def create_table(
         Create a YDB table.
 
         :param path: A table path
-        :param table_description: TableDescription instanse.
+        :param table_description: TableDescription instance.
         :param settings: An instance of BaseRequestSettings that describes how rpc should be invoked.
 
         :return: Operation or YDB error otherwise.
@@ -1881,7 +1881,7 @@ def prepare(self, query, settings=None):
 
     def explain(self, yql_text, settings=None):
         """
-        Expiremental API.
+        Experimental API.
 
         :param yql_text:
         :param settings:
@@ -2556,7 +2556,7 @@ def _set_finish(self, val):
 
     def _check_split(self, allow=""):
         """
-        Deny all operaions with transaction after commit/rollback.
+        Deny all operations with transaction after commit/rollback.
         Exception: double commit and double rollbacks, because it is safe
         """
         allow_split_transaction = (