diff --git a/src/jobs/jobs.service.ts b/src/jobs/jobs.service.ts index c0e1011..1cdeb08 100644 --- a/src/jobs/jobs.service.ts +++ b/src/jobs/jobs.service.ts @@ -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); } }