chore: fix

Author: ovr

packages/cubejs-cubestore-driver/src/CubeStoreQueueDriver.ts

@@ -174,8 +174,6 @@ class CubestoreQueueDriverConnection implements QueueDriverConnectionInterface {
         toProcess.push(row.id as string);
       } else if (row.status === 'active') {
         active.push(row.id as string);
-        // TODO: getQueryStage is broken for Executing query stage...
-        toProcess.push(row.id as string);
       }
     }
 

packages/cubejs-query-orchestrator/src/orchestrator/QueryQueue.js

@@ -658,7 +658,9 @@ export class QueryQueue {
         };
       }
 
-      const index = toProcess.indexOf(this.redisHash(queryInQueue.queryKey));
+      const index = toProcess
+        .filter((queryKey) => (priorityFilter != null ? allQueryDefs[queryKey]?.priority === priorityFilter : true))
+        .indexOf(this.redisHash(queryInQueue.queryKey));
       if (index !== -1) {
         return index !== -1 ? { stage: `#${index + 1} in queue` } : undefined;
       }