Effect.All with {concurrency: N} means taking a new job as far as previous one ended. This doesn't really work for my usecase... What I want to do is take N jobs, process them in parallel and wait till all of them are done before taking another N jobs.UnboundedQueue + takeUpTo but maybe I am missing something.