We at least have our own thread already. The enxt step is to unwrap the agglomerate function into smaller chunks