From 31b95b5f17102860ec922ecf8b5a1f03ae250bfe Mon Sep 17 00:00:00 2001 From: Tom Moor Date: Sun, 10 Apr 2022 20:05:59 -0700 Subject: [PATCH] fix: BaseProcessor should not be pushed onto queues --- server/services/worker.ts | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/server/services/worker.ts b/server/services/worker.ts index a21383a2e..b684f91f9 100644 --- a/server/services/worker.ts +++ b/server/services/worker.ts @@ -46,10 +46,7 @@ export default function init() { // websockets are a special case on their own queue because they must // only be consumed by the websockets service rather than workers. await websocketQueue.add(job.data); - } else if ( - ProcessorClass.applicableEvents.length === 0 || - ProcessorClass.applicableEvents.includes(event.name) - ) { + } else if (ProcessorClass.applicableEvents.includes(event.name)) { await processorEventQueue.add({ event, name }); } } catch (error) {