feat: longer digest

This commit is contained in:
Nevo David 2026-01-07 01:22:02 +07:00
parent 475cf8e0fb
commit 7001295fa5
1 changed files with 1 additions and 1 deletions

View File

@ -32,7 +32,7 @@ export async function digestEmailWorkflow({
while (true) {
await condition(() => queue.length > 0);
await sleep(3600000);
await sleep(60000);
// Take a snapshot batch and immediately clear queue.
const batch = queue.splice(0, queue.length);