this repo has no description
fix? maybe?????
+3
-3
+3
-3
src/stages/stage3.ts
+3
-3
src/stages/stage3.ts
···
208
208
}),
209
209
);
210
210
211
-
const chunkedTasks = chunkArray(tasks, SUCCESSFUL_DIDS_LOG_INTERVAL);
211
+
const chunkedTasks = chunkArray(tasks, Math.floor(SUCCESSFUL_DIDS_LOG_INTERVAL / 10));
212
212
for (const chunk of chunkedTasks) {
213
213
try {
214
214
await Promise.all(chunk);
···
288
288
console.error(`Redis set error for DID ${did}: ${(redisError as Error).message}`);
289
289
}
290
290
291
-
didsProcessedTotal.inc();
292
-
293
291
throw err;
292
+
} finally {
293
+
didsProcessedTotal.inc();
294
294
}
295
295
}
296
296