def __init__(self, output_plugin=None, **kwargs):

    if not output_plugin:
      raise ValueError("output_plugin can't be None")
    self.output_plugin = output_plugin

    self.batches_count = 0
    self.lock = threading.RLock()

    super(OutputPluginBatchConverter, self).__init__(**kwargs)
Constructor.
dataset/ETHPy150Open google/grr/grr/tools/export_plugins/plugin.py/OutputPluginBatchConverter.__init__