def _main(self):
probes = self.config.get('<STR_LIT>', None)<EOL>if not probes:<EOL><INDENT>raise ValueError('<STR_LIT>')<EOL><DEDENT>for probe_config in self.config['<STR_LIT>']:<EOL><INDENT>probe = plugin.get_probe(probe_config, self.plugin_context)<EOL>if '<STR_LIT>' not in probe_config:<EOL><INDENT>raise ValueError("<STR_LIT>")<EOL><DEDENT>for output_name in probe_config['<STR_LIT>']:<EOL><INDENT>output = plugin.get_output(output_name, self.plugin_context)<EOL>if not output.started:<EOL><INDENT>output.start()<EOL>self.joins.append(output)<EOL><DEDENT>probe._emit.append(output)<EOL><DEDENT>probe.start()<EOL>self.joins.append(probe)<EOL><DEDENT>vaping.io.joinall(self.joins)<EOL>return <NUM_LIT:0><EOL>
process