fix: BaseProcessor should not be pushed onto queues

2022-04-10 20:05:59 -07:00
parent 963475d2b0
commit 31b95b5f17
1 changed files with 1 additions and 4 deletions
--- 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) {