def _callback_handler(self, data):
    """Callback for when messages are recieved from pusher."""
    try:
      events = json.loads(data)
    except __HOLE__:
      logging.error('Error parsing message', exc_info=sys.exc_info())
      return

    # pylint: disable=broad-except
    try:
      self._callback(events)
    except Exception:
      logging.error('Error running push callback', exc_info=sys.exc_info())
dataset/ETHPy150Open tomwilkie/awesomation/src/pi/pushrpc.py/PushRPC._callback_handler