def _ProcessValuesWithOutputPlugin(self, values, output_plugin, args):

    checkpoints = utils.Grouper(values, args.checkpoint_every)
    for index, checkpoint in enumerate(checkpoints):
      logging.info("Starting checkpoint %d.", index)
      batch_converter = OutputPluginBatchConverter(
          batch_size=args.batch, threadpool_size=args.threads,
          output_plugin=output_plugin)
      batch_converter.Convert(checkpoint)

      logging.info("Checkpointing (checkpoint %d)...", index)
      output_plugin.Flush()
      logging.info("Checkpoint %d done.", index)
The size in bytes up to which ``IDeployer`` will round volume
dataset/ETHPy150Open google/grr/grr/tools/export_plugins/plugin.py/OutputPluginBasedExportPlugin._ProcessValuesWithOutputPlugin--crossover with--dataset/ETHPy150Open ClusterHQ/flocker/flocker/node/agents/blockdevice.py/IBlockDeviceAPI.allocation_unit