moved aggregation to pulsedb_worker