class_docstr: The implement of DialogReader.
code: def _distributed_batch_reader(
      self, batch_reader, num_part, part_id, is_test=False
  ):
      def __wrapper__():
          batches = []
          for batch in batch_reader():
              batches.append(batch)
              if len(batches) == num_part:
                  yield batches[part_id]
                  batches = []
          if is_test and 0 <= part_id < len(batches):
              yield batches[part_id]
          return
  
      return __wrapper__
  
imports: import csv
  from collections import namedtuple
  from contextlib import contextmanager
  import gzip
  import numpy
  from ..utils import pad_batch_data
  from ..utils.args import str2bool
  from ..utils.masking import mask
  from ..utils import tokenization
label_desc: Use image node_id 10 for calling the DialogReader obj's underlying member method code with example usage: obj._distributed_batch_reader(batch_reader, num_part, part_id, is_test) and returns: __wrapper__