function getUpserts() {
return E.gen(function* () {
const [upsertEffects, skippedUpserts] = yield* foo();
if (skippedUpserts.length > 0) {
E.runFork(
E.logWarning(
`Some upserts skipped due to missing: `,
JSON.stringify(skippedUpserts),
),
);
}
return E.all(upsertEffects, { concurrency: "unbounded" });
});
}
function getUpserts() {
return E.gen(function* () {
const [upsertEffects, skippedUpserts] = yield* foo();
if (skippedUpserts.length > 0) {
E.runFork(
E.logWarning(
`Some upserts skipped due to missing: `,
JSON.stringify(skippedUpserts),
),
);
}
return E.all(upsertEffects, { concurrency: "unbounded" });
});
}