Skip to content

Commit 7142e9c

Browse files
authored
feat(cubestore-driver): Queue - protect possible race condition on removing orphaned queries (#7426)
1 parent a2e42ac commit 7142e9c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -515,7 +515,7 @@ export class QueryQueue {
515515
const toCancel = await queueConnection.getQueriesToCancel();
516516

517517
await Promise.all(toCancel.map(async ([queryKey, queueId]) => {
518-
const [queryDef] = await queueConnection.getQueryAndRemove(queryKey);
518+
const [queryDef] = await queueConnection.getQueryAndRemove(queryKey, queueId);
519519
if (queryDef) {
520520
this.logger('Removing orphaned query', {
521521
queueId: queueId || queryDef.queueId /** Special handling for Redis */,

0 commit comments

Comments
 (0)