Implementing a Concurrent Pipeline with Effect and Concurrency

I'm really struggling to get a simple pipeline in place... Given the following:

const getRows: Effect<Row[], Error, DB>
const processRow: (row: Row) => Effect<Result, Error, API>

const getRows: Effect<Row[], Error, DB>
const processRow: (row: Row) => Effect<Result, Error, API>

I'd like to simply get the rows, then process all of the rows with a concurrency of N.

Implementing a Concurrent Pipeline with Effect and Concurrency - Effect Community