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) {