code: def UpdateNumberOfEventTags(
        self, number_of_consumed_event_tags, number_of_produced_event_tags):
      
      consumed_event_tags_delta = 0
      if number_of_consumed_event_tags is not None:
        if number_of_consumed_event_tags < self.number_of_consumed_event_tags:
          raise ValueError(
              'Number of consumed event tags smaller than previous update.')
  
        consumed_event_tags_delta = (
            number_of_consumed_event_tags - self.number_of_consumed_event_tags)
  
        self.number_of_consumed_event_tags = number_of_consumed_event_tags
        self.number_of_consumed_event_tags_delta = consumed_event_tags_delta
  
      produced_event_tags_delta = 0
      if number_of_produced_event_tags is not None:
        if number_of_produced_event_tags < self.number_of_produced_event_tags:
          raise ValueError(
              'Number of produced event tags smaller than previous update.')
  
        produced_event_tags_delta = (
            number_of_produced_event_tags - self.number_of_produced_event_tags)
  
        self.number_of_produced_event_tags = number_of_produced_event_tags
        self.number_of_produced_event_tags_delta = produced_event_tags_delta
  
      return consumed_event_tags_delta > 0 or produced_event_tags_delta > 0
docs: Updates the number of event tags.
  
      Args:
        number_of_consumed_event_tags (int): total number of event tags consumed
            by the process.
        number_of_produced_event_tags (int): total number of event tags produced
            by the process.
  
      Returns:
        bool: True if either number of event tags has increased.
  
      Raises:
        ValueError: if the consumed or produced number of event tags is smaller
            than the value of the previous update.