from .processors import AsyncAmplitudeProcessor from .collectors import Collector user_events = Collector() user_events.attach_processor(AsyncAmplitudeProcessor())