const getPendingJobs = Effect.promise(async () => {
// Do things...
return [
{
id: "my-job",
details: "some details",
}
]
});
const runJob = (job: SomeType){
console.log(job.id)
};
export const runPendingAIJobs = () => {
return Effect.gen(function* () {
const pendingJobs = yield* getPendingJobs;
const results = yield* Effect.all(
pendingJobs.map((job) => {
return runJob(job);
}),
{
concurrency: 20
}
);
});
};
const getPendingJobs = Effect.promise(async () => {
// Do things...
return [
{
id: "my-job",
details: "some details",
}
]
});
const runJob = (job: SomeType){
console.log(job.id)
};
export const runPendingAIJobs = () => {
return Effect.gen(function* () {
const pendingJobs = yield* getPendingJobs;
const results = yield* Effect.all(
pendingJobs.map((job) => {
return runJob(job);
}),
{
concurrency: 20
}
);
});
};