From 9f91b9ad344f4d478ef20f2e8f92d0a0974f2f14 Mon Sep 17 00:00:00 2001 From: syuilo Date: Thu, 14 Mar 2019 21:51:33 +0900 Subject: [PATCH] Fix bug --- src/queue/index.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/queue/index.ts b/src/queue/index.ts index 479b8defa..d8328a1d5 100644 --- a/src/queue/index.ts +++ b/src/queue/index.ts @@ -178,10 +178,10 @@ export function destroy() { deliverQueue.once('cleaned', (jobs, status) => { deliverLogger.succ(`Cleaned ${jobs.length} ${status} jobs`); }); - deliverQueue.clean(0, 'wait'); + deliverQueue.clean(0, 'delayed'); inboxQueue.once('cleaned', (jobs, status) => { inboxLogger.succ(`Cleaned ${jobs.length} ${status} jobs`); }); - inboxQueue.clean(0, 'wait'); + inboxQueue.clean(0, 'delayed'); }