Reads from D1 bycaliber.events where source_class='email'. Implementation pending.
bycaliber.events
source_class='email'