@cubejs-backend/base-driver - npm Package Compare versions

Comparing version 0.34.1 to 0.34.11

dist/src/queue-driver.interface.d.ts

@@ -10,3 +10,4 @@ export type QueryDef = unknown;
 }
-export type GetActiveAndToProcessResponse = [active: string[], toProcess: string[]];
+export type QueryKeysTuple = [keyHash: QueryKeyHash, queueId: QueueId | null /** Supported by new Cube Store and Memory */];
+export type GetActiveAndToProcessResponse = [active: QueryKeysTuple[], toProcess: QueryKeysTuple[]];
 export type AddToQueueResponse = [added: number, queueId: QueueId | null, queueSize: number, addedToQueueTime: number];
@@ -39,3 +40,3 @@ export type QueryStageStateResponse = [active: string[], toProcess: string[]] | [active: string[], toProcess: string[], defs: Record<string, QueryDef>];
     orphanedTimeout?: number;
-    queueId?: QueueId;
+    queueId: QueueId;
 }
@@ -68,7 +69,7 @@ export interface QueueDriverOptions {
     addToQueue(keyScore: number, queryKey: QueryKey, orphanedTime: number, queryHandler: string, query: AddToQueueQuery, priority: number, options: AddToQueueOptions): Promise<AddToQueueResponse>;
-    getToProcessQueries(): Promise<string[]>;
-    getActiveQueries(): Promise<string[]>;
+    getToProcessQueries(): Promise<QueryKeysTuple[]>;
+    getActiveQueries(): Promise<QueryKeysTuple[]>;
     getQueryDef(hash: QueryKeyHash, queueId: QueueId | null): Promise<QueryDef | null>;
-    getOrphanedQueries(): Promise<string[]>;
-    getStalledQueries(): Promise<string[]>;
+    getOrphanedQueries(): Promise<QueryKeysTuple[]>;
+    getStalledQueries(): Promise<QueryKeysTuple[]>;
     getQueryStageState(onlyKeys: boolean): Promise<QueryStageStateResponse>;
@@ -84,3 +85,3 @@ updateHeartBeat(hash: QueryKeyHash): Promise<void>;
     release(): void;
-    getQueriesToCancel(): Promise<string[]>;
+    getQueriesToCancel(): Promise<QueryKeysTuple[]>;
     getActiveAndToProcess(): Promise<GetActiveAndToProcessResponse>;
@@ -87,0 +88,0 @@ }

package.json

@@ -5,3 +5,3 @@ {
   "author": "Cube Dev, Inc.",
-  "version": "0.34.1",
+  "version": "0.34.11",
   "repository": {
@@ -66,3 +66,3 @@ "type": "git",
   },
-  "gitHead": "c23b8a2fb099c732aef96236f580556ef53ee4d2"
+  "gitHead": "21cb1a45800d9950af89c965af9fb53d053a6f77"
 }

No alert changes

Improved metrics

Total package byte prevSize

76106

increased by0.36%

Lines of code

825

increased by0.12%

No dependency changes