@shared_task<EOL>def process_events(event_types):
results = []<EOL>for e in event_types:<EOL><INDENT>processor = current_stats.events[e].processor_class(<EOL>**current_stats.events[e].processor_config)<EOL>results.append((e, processor.run()))<EOL><DEDENT>return results<EOL>
Index statistics events.