code: def _consume(self, data_sinks, cube, global_iter_args):
          
          try:
              return self._consume_impl(data_sinks, cube, global_iter_args)
          except Exception as e:
              montblanc.log.exception("Consumer Exception")
              raise e, None, sys.exc_info()[2]
docs: Consume stub