@cubejs-backend/query-orchestrator - npm Package Compare versions

Comparing version 0.10.30 to 0.10.32

CHANGELOG.md

@@ -6,2 +6,13 @@ # Change Log
 
+## [0.10.32](https://github.com/statsbotco/cubejs-client/compare/v0.10.31...v0.10.32) (2019-09-06)
+
+
+### Bug Fixes
+
+* In memory queue driver drop state if rollups are building too long ([ad4c062](https://github.com/statsbotco/cubejs-client/commit/ad4c062))
+
+
+
+
+
 ## [0.10.30](https://github.com/statsbotco/cubejs-client/compare/v0.10.29...v0.10.30) (2019-08-26)
@@ -8,0 +19,0 @@

orchestrator/LocalCacheDriver.js

@@ -0,4 +1,6 @@
+const store = {};
+
 class LocalCacheDriver {
   constructor() {
-    this.store = {};
+    this.store = store;
   }
@@ -5,0 +7,0 @@

orchestrator/LocalQueueDriver.js

@@ -173,2 +173,9 @@ const R = require('ramda');
 
+const results = {};
+const resultPromises = {};
+const queryDef = {};
+const toProcess = {};
+const recent = {};
+const active = {};
+
 class LocalQueueDriver extends BaseQueueDriver {
@@ -178,8 +185,8 @@ constructor(options) {
     this.options = options;
-    this.results = {};
-    this.resultPromises = {};
-    this.queryDef = {};
-    this.toProcess = {};
-    this.recent = {};
-    this.active = {};
+    this.results = results;
+    this.resultPromises = resultPromises;
+    this.queryDef = queryDef;
+    this.toProcess = toProcess;
+    this.recent = recent;
+    this.active = active;
   }
@@ -186,0 +193,0 @@

package.json

@@ -5,3 +5,3 @@ {
   "author": "Statsbot, Inc.",
-  "version": "0.10.30",
+  "version": "0.10.32",
   "engines": {
@@ -24,3 +24,3 @@ "node": ">=8.11.1"
   "license": "Apache-2.0",
-  "gitHead": "4c835abe39cac254ea6e3ac82cc26523a9e85240"
+  "gitHead": "7f5981ac0b3325e0c632f6fba185e49e0a2fc36a"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

78014

increased by0.58%

Lines of code

1599

increased by0.44%

No dependency changes