Fix excessive logs from the MarQS rebalancer

Author: ericallam

apps/webapp/app/v3/marqs/index.server.ts

@@ -69,7 +69,6 @@ export class MarQS {
   private redis: Redis;
   public keys: MarQSKeyProducer;
   private queuePriorityStrategy: MarQSQueuePriorityStrategy;
-  #requeueingWorkers: Array<AsyncWorker> = [];
   #rebalanceWorkers: Array<AsyncWorker> = [];
 
   constructor(private readonly options: MarQSOptions) {
@@ -846,10 +845,14 @@ export class MarQS {
       });
 
       stream.on("data", async (keys) => {
-        stream.pause();
-
         const uniqueKeys = Array.from(new Set<string>(keys));
 
+        if (uniqueKeys.length === 0) {
+          return;
+        }
+
+        stream.pause();
+
         logger.debug("Rebalancing parent queues", {
           component: "marqs",
           operation: "rebalanceParentQueues",