code: def run(self, raw_message):
      # Atmosphere framework sends heartbeat messages every minute, we have to ignore them
      if raw_message is not None and not self._is_heartbeat(
          raw_message
      ):
          message = Message.from_json(json.loads(raw_message))
          self._process_message(message)
  
file_path: neptune-client/src/neptune/legacy/internal/websockets/websocket_message_processor.py
imports: import json
  from neptune.legacy.internal.websockets.message import Message
label_desc: Use image node_id 2 for calling the WebsocketMessageProcessor obj's underlying member method code with example usage: obj.run(raw_message) without return types