File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
packages/cubejs-query-orchestrator/src/orchestrator Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -716,7 +716,7 @@ export class QueryQueue {
716716 * of the logic related with the queues updates, heartbeat, etc.
717717 *
718718 * @param {QueryKeyHash } queryKeyHashed
719- * @param {QueueId | null } queueId Real queue id, only for Cube Store
719+ * @param {QueueId | null } queueId Supported by new Cube Store and Memory
720720 * @return {Promise<{ result: undefined | Object, error: string | undefined }> }
721721 */
722722 async processQuery ( queryKeyHashed , queueId ) {
@@ -729,7 +729,7 @@ export class QueryQueue {
729729 let processingLockAcquired ;
730730
731731 try {
732- const processingId = await queueConnection . getNextProcessingId ( ) ;
732+ const processingId = queueId || /** for Redis only */ await queueConnection . getNextProcessingId ( ) ;
733733 const retrieveResult = await queueConnection . retrieveForProcessing ( queryKeyHashed , processingId ) ;
734734
735735 if ( retrieveResult ) {
You can’t perform that action at this time.
0 commit comments