Skip to content

bug: apply max_messages and max_bytes parameters #365

Open
@rekby

Description

@rekby

Bug Report

YDB Python SDK version: 3.5.1

def receive_batch(
self,
*,
max_messages: typing.Union[int, None] = None,
max_bytes: typing.Union[int, None] = None,
timeout: Union[float, None] = None,
) -> Union[PublicBatch, None]:
"""

Example of calc size for a message:

def _split_messages_by_size_with_default_overhead(
messages: List[InternalMessage],
) -> List[List[InternalMessage]]:
def get_message_size(msg: InternalMessage):
return len(msg.data) + _message_data_overhead
return _split_messages_by_size(messages, connection._DEFAULT_MAX_GRPC_MESSAGE_SIZE, get_message_size)

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't workingtopic

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions