Skip to content

Commit dcdfce1

Browse files
committed
chore: fix
1 parent 14daeac commit dcdfce1

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -152,12 +152,14 @@ export class LocalQueueDriverConnection {
152152
}
153153

154154
let added = 0;
155-
if (!this.toProcess[key]) {
155+
156+
if (!this.toProcess[key] && !this.active[key]) {
156157
this.toProcess[key] = {
157158
order: keyScore,
158159
queueId: options.queueId,
159160
key
160161
};
162+
161163
added = 1;
162164
}
163165

0 commit comments

Comments
 (0)