boki/stock-bot
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

working on queue

Browse source
This commit is contained in:
Boki 2025-06-11 09:53:04 -04:00
parent 58c5ba1200
commit fe7733aeb5
5 changed files with 105 additions and 34 deletions
Download patch file Download diff file Expand all files Collapse all files

4
apps/data-service/src/utils/batch-helpers.ts
View file

@ -110,7 +110,7 @@ async function processDirect<T>(
): Promise<Omit<BatchResult, 'duration'>> {
const totalDelayMs = options.totalDelayHours * 60 * 60 * 1000;
const delayPerItem = Math.floor(totalDelayMs / items.length);
const delayPerItem = totalDelayMs / items.length;
logger.info('Creating direct jobs', {
totalItems: items.length,
@ -157,7 +157,7 @@ async function processBatched<T>(
const batchSize = options.batchSize || 100;
const batches = createBatches(items, batchSize);
const totalDelayMs = options.totalDelayHours * 60 * 60 * 1000;
const delayPerBatch = Math.floor(totalDelayMs / batches.length);
const delayPerBatch = totalDelayMs / batches.length;
logger.info('Creating batch jobs', {
totalItems: items.length,