code: def parse_cluster_pubsub_numpat(res, **options):
      
      aggregate = options.get('aggregate', True)
      if not aggregate:
          return res
  
      numpat = 0
      for node, node_numpat in res.items():
          numpat += node_numpat
      return numpat
docs: Result callback, handles different return types
      switchable by the `aggregate` flag.