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

Comparing version 0.32.0 to 0.32.2

dist/src/BaseDriver.d.ts

@@ -13,2 +13,3 @@ /**
 export declare abstract class BaseDriver implements DriverInterface {
+    private testConnectionTimeoutValue;
     protected logger: any;
@@ -18,3 +19,9 @@ /**
      */
-    constructor(_options?: {});
+    constructor(_options?: {
+        /**
+         * Time to wait for a response from a connection after validation
+         * request before determining it as not valid. Default - 10000 ms.
+         */
+        testConnectionTimeout?: number;
+    });
     protected informationSchemaQuery(): string;
@@ -21,0 +28,0 @@ /**

dist/src/BaseDriver.js

@@ -93,3 +93,4 @@ "use strict";
     constructor(_options = {}) {
-        //
+        this.testConnectionTimeoutValue = 10000;
+        this.testConnectionTimeoutValue = _options.testConnectionTimeout || 10000;
     }
@@ -224,3 +225,3 @@ informationSchemaQuery() {
     testConnectionTimeout() {
-        return 10000;
+        return this.testConnectionTimeoutValue;
     }
@@ -227,0 +228,0 @@ async downloadTable(table, _options) {

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

@@ -10,3 +10,19 @@ export type QueryDef = unknown;
 export type QueryStageStateResponse = [active: string[], toProcess: string[]] | [active: string[], toProcess: string[], defs: Record<string, QueryDef>];
-export type RetrieveForProcessingResponse = [added: any, removed: any, active: QueryKeyHash[], toProcess: any, def: QueryDef, lockAquired: boolean] | null;
+export type RetrieveForProcessingSuccess = [
+    added: any /** todo(ovr): Remove, useless */,
+    removed: any /** todo(ovr): Remove, useless */,
+    active: QueryKeyHash[],
+    pending: number,
+    def: QueryDef,
+    lockAquired: true
+];
+export type RetrieveForProcessingFail = [
+    added: any /** todo(ovr): Remove, useless */,
+    removed: any /** todo(ovr): Remove, useless */,
+    active: QueryKeyHash[],
+    pending: number,
+    def: null,
+    lockAquired: false
+];
+export type RetrieveForProcessingResponse = RetrieveForProcessingSuccess | RetrieveForProcessingFail | null;
 export interface AddToQueueQuery {
@@ -13,0 +29,0 @@ isJob: boolean;

package.json

@@ -5,3 +5,3 @@ {
   "author": "Cube Dev, Inc.",
-  "version": "0.32.0",
+  "version": "0.32.2",
   "repository": {
@@ -33,3 +33,3 @@ "type": "git",
   "dependencies": {
-    "@cubejs-backend/shared": "^0.32.0",
+    "@cubejs-backend/shared": "^0.32.2",
     "ramda": "^0.27.0"
@@ -67,3 +67,3 @@ },
   },
-  "gitHead": "42f54aed393b75c93704f6205c123bf325639923"
+  "gitHead": "8f3dafc3132004641e40c3750ea1762bed1a4a38"
 }

No alert changes

Improved metrics

Total package byte prevSize

67248

increased by1.92%

Lines of code

714

increased by3.48%

Dependency changes

• Updated@cubejs-backend/shared@^0.32.2