docs: def batch_results(self, results):
      """Push a batch of output results to the Spark output RDD of ``TFCluster.inference()``.
  
      Note: this currently expects a one-to-one mapping of input to output data, so the length of the ``results`` array should match the length of
      the previously retrieved batch of input data.
  
      Args:
        :results: array of output data for the equivalent batch of input data.
      """
      logging.debug("batch_results() invoked")
      queue = self.mgr.get_queue(self.qname_out)
      for item in results:
        queue.put(item, block=True)
      logging.debug("batch_results() returning data")