def _is_throttled(event):
  """Checks if the message has been throttled already.

  Args:
    event: The pub/sub event object

  Returns:
    True if contains an attribute called "forwarded"
    False in any other case
  """
  return (event.get('attributes') is
          not None) and (event.get('attributes').get('forwarded') is not None)