code: def get(self) -> Union[Event, None]:
          
          message = self._queue.get_message()
          if message and message['type'] == 'message':
              event_id = DB.get_event(self._pub_key, self._processed_key)
              event_data_str = DB.get_hash_value(self._data_key, event_id)
              event_dict = ast.literal_eval(event_data_str)
              event_dict['id'] = event_id
              event_dict['subscriber'] = self._subscriber
              return Event.from_config(event_dict)
          return None
docs: Get the latest event from the queue.
  
          Call this method to query the queue for the latest event.
  
          If no event has been published None is returned.
  
          Returns:
                Event or None