def METHOD_NAME(ws_app: WebSocketApp, msg: str):
    # We strongly trust that the contract on API will hold atm :D
    event_dict = json.loads(msg)
    labels = _LogEventLabels(**event_dict.get("labels", {}))
    if "message" in event_dict:
        message = event_dict["message"]
        timestamp = dateutil.parser.isoparse(event_dict["timestamp"])
        event = _LogEvent(
            message=message,
            timestamp=timestamp,
            component_name=component_name,
            labels=labels,
        )
        read_queue.put(event)