def METHOD_NAME(role, file):
  with open(os.path.join(self.output_directory,
                         os.path.basename(file)), 'r') as f:
    fp = iter(f)
    labels, out = dstat.ParseCsvFile(fp)
    background_tasks.RunThreaded(
        _AnalyzeEvent,
        [((role, labels, out, e), {}) for e in events.TracingEvent.events],
    )