check_msg_error

def check_msg_error(msg: Optional[Message]) -> Optional[Message]:
    """Checks for errors in the consumed message.

    Args:
        msg (Message): The message to check for errors.

    Returns:
        Message: The original message if no error is found, otherwise None.
    """
    if msg is None:
        return msg
    if msg.error():
        return None
    return msg