code: def count_exceptions(self, c, broker):
          
          if c in broker.exceptions:
              self.counts['exception'] += len(broker.exceptions[c])
          return self
docs: Count exceptions as processing proceeds