diff --git a/ydb/_topic_common/common.py b/ydb/_topic_common/common.py index 678f5ff61..3007b32a0 100644 --- a/ydb/_topic_common/common.py +++ b/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() diff --git a/ydb/_topic_writer/topic_writer_asyncio.py b/ydb/_topic_writer/topic_writer_asyncio.py index ff9c59f79..81b9e7191 100644 --- a/ydb/_topic_writer/topic_writer_asyncio.py +++ b/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. diff --git a/ydb/convert.py b/ydb/convert.py index fb760d279..66ecf5625 100644 --- a/ydb/convert.py +++ b/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: diff --git a/ydb/driver.py b/ydb/driver.py index 814408ad6..12b8519b6 100644 --- a/ydb/driver.py +++ b/ydb/driver.py @@ -312,7 +312,7 @@ def __init__( :param connection_string: A string in the following format: ://:/?database=/path/to/the/database :param endpoint: An endpoint specified in the following format: ://: :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 diff --git a/ydb/retries.py b/ydb/retries.py index 1efd211db..4e352b5dc 100644 --- a/ydb/retries.py +++ b/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 diff --git a/ydb/scheme.py b/ydb/scheme.py index 4f84ddaa1..fd0630f8b 100644 --- a/ydb/scheme.py +++ b/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( diff --git a/ydb/table.py b/ydb/table.py index 765570cbe..8fbc5e780 100644 --- a/ydb/table.py +++ b/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 = (