code: def parse_monitor_message(msg):
      """decode zmq_monitor event messages.
  
      Parameters
      ----------
      msg : list(bytes)
          zmq multipart message that has arrived on a monitor PAIR socket.
  
          First frame is::
  
              16 bit event id
              32 bit event value
              no padding
  
          Second frame is the endpoint as a bytestring
  
      Returns
      -------
      event : dict
          event description as dict with the keys `event`, `value`, and `endpoint`.
      """
  
      if len(msg) != 2 or len(msg[0]) != 6:
          raise RuntimeError("Invalid event message format: %s" % msg)
      event = {
          "event": struct.unpack("=hi", msg[0])[0],
          "value": struct.unpack("=hi", msg[0])[1],
          "endpoint": msg[1],
      }
      return event
  
imports: import struct
  import zmq
  from zmq.error import _check_version
label_desc: Use image node_id 1 for calling a global function with example usage: parse_monitor_message(msg) and returns: event