File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
packages/cubejs-query-orchestrator/src/orchestrator Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -21,15 +21,15 @@ import {
2121
2222export interface QueueItem {
2323 order : number ;
24- key : any ;
24+ key : QueryKeyHash ;
2525 queueId : QueueId ;
2626}
2727
2828export interface QueryDefObject {
2929 queueId : QueueId ;
3030 queryHandler : string ;
3131 query : any ;
32- queryKey : any ;
32+ queryKey : QueryKey ;
3333 stageQueryKey : string ;
3434 priority : number ;
3535 requestId : string ;
@@ -143,7 +143,7 @@ export class LocalQueueDriverConnection implements QueueDriverConnectionInterfac
143143 return null ;
144144 }
145145
146- protected queueArray ( queueObj : Record < string , QueueItem > , orderFilterLessThan ?: number ) : string [ ] {
146+ protected queueArray ( queueObj : Record < QueryKeyHash , QueueItem > , orderFilterLessThan ?: number ) : string [ ] {
147147 return R . pipe (
148148 R . values ,
149149 R . filter ( orderFilterLessThan ? ( q : QueueItem ) => q . order < orderFilterLessThan : R . identity ) ,
@@ -152,7 +152,7 @@ export class LocalQueueDriverConnection implements QueueDriverConnectionInterfac
152152 ) ( queueObj ) ;
153153 }
154154
155- protected queueArrayAsTuple ( queueObj : Record < string , QueueItem > , orderFilterLessThan ?: number ) : QueryKeysTuple [ ] {
155+ protected queueArrayAsTuple ( queueObj : Record < QueryKeyHash , QueueItem > , orderFilterLessThan ?: number ) : QueryKeysTuple [ ] {
156156 return R . pipe (
157157 R . values ,
158158 R . filter ( orderFilterLessThan ? ( q : QueueItem ) => q . order < orderFilterLessThan : R . identity ) ,
You can’t perform that action at this time.
0 commit comments