fix: In memory queue driver drop state if rollups are building too long

cube-js · Sep 6, 2019 · ad4c062 · ad4c062
1 parent 0beb711
commit ad4c062
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 7 deletions.
diff --git a/packages/cubejs-query-orchestrator/orchestrator/LocalCacheDriver.js b/packages/cubejs-query-orchestrator/orchestrator/LocalCacheDriver.js
@@ -1,6 +1,8 @@
+const store = {};
+
 class LocalCacheDriver {
   constructor() {
-    this.store = {};
+    this.store = store;
   }
 
   async get(key) {

diff --git a/packages/cubejs-query-orchestrator/orchestrator/LocalQueueDriver.js b/packages/cubejs-query-orchestrator/orchestrator/LocalQueueDriver.js
@@ -170,16 +170,23 @@ class LocalQueueDriverConnection {
   }
 }
 
+const results = {};
+const resultPromises = {};
+const queryDef = {};
+const toProcess = {};
+const recent = {};
+const active = {};
+
 class LocalQueueDriver extends BaseQueueDriver {
   constructor(options) {
     super();
     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;
   }
 
   createConnection() {