Parallelize correlated subqueries that execute within each worker

Parallelize correlated subqueries that execute within each worker

Edit