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