Understanding the Effect Library and Refactoring Async/Await Functions

export async function main(event: SQSEvent) {
    const records: SQSRecord[] = event.Records;
    if (records.length > 0) {
        records.forEach(async (record) => {
            const [data, parseError] = parseRecord(record)
            if (data == null) {
                console.error(parseError)
                return false
            }
            const [canContinue, retryError] = await checkJobRetryCount({ userId: data.userId, jobId: data.jobId })
            if (!canContinue) {
                console.error(retryError)
                return false
            }
            return true
        });
    }

    return {};
}

const process = pipe(
    record,
    parseRecord,
    Effect.flatMap(checkJobRetryCount)
Effect.flaMap(nextFunction)
)