File tree Expand file tree Collapse file tree 1 file changed +5
-6
lines changed
packages/cubejs-query-orchestrator/src/orchestrator Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -174,16 +174,15 @@ export class LocalQueueDriverConnection implements QueueDriverConnectionInterfac
174174 } ;
175175
176176 const key = this . redisHash ( queryKey ) ;
177- const keyStr = key as string ;
178177
179- if ( ! this . state . queryDef [ keyStr ] ) {
180- this . state . queryDef [ keyStr ] = queryQueueObj ;
178+ if ( ! this . state . queryDef [ key ] ) {
179+ this . state . queryDef [ key ] = queryQueueObj ;
181180 }
182181
183182 let added = 0 ;
184183
185- if ( ! this . state . toProcess [ keyStr ] && ! this . state . active [ keyStr ] ) {
186- this . state . toProcess [ keyStr ] = {
184+ if ( ! this . state . toProcess [ key ] && ! this . state . active [ key ] ) {
185+ this . state . toProcess [ key ] = {
187186 order : keyScore ,
188187 queueId : options . queueId ,
189188 key
@@ -192,7 +191,7 @@ export class LocalQueueDriverConnection implements QueueDriverConnectionInterfac
192191 added = 1 ;
193192 }
194193
195- this . state . recent [ keyStr ] = {
194+ this . state . recent [ key ] = {
196195 order : orphanedTime ,
197196 key,
198197 queueId : options . queueId ,
You can’t perform that action at this time.
0 commit comments