Switch to split than aperture

This commit is contained in:
2024-04-25 17:16:05 -06:00
parent e3682dfae6
commit 605b2c1cfe

View File

@@ -4,7 +4,7 @@ import Redis from 'ioredis'
import { InjectRedis } from '@liaoliaots/nestjs-redis';
import { CACHE_MANAGER } from '@nestjs/cache-manager';
import { Cache } from 'cache-manager';
import { aperture } from 'ramda';
import { aperture, splitEvery } from 'ramda';
export interface JobMetadata {
name: string;
@@ -110,8 +110,8 @@ export class JobsService {
async addItemsToJob(jobName: string, items: string[]) {
const apertureSize = 100
for (const itemSubset of (items.length > apertureSize ? aperture(apertureSize, items) : [items])) {
const splitSize = 500
for (const itemSubset of (items.length > splitSize ? splitEvery(splitSize, items) : [items])) {
await this.redis.rpush(this.todoListNameBuilder(jobName), ...itemSubset);
}
}