diff --git a/packages/cubejs-query-orchestrator/orchestrator/LocalCacheDriver.js b/packages/cubejs-query-orchestrator/orchestrator/LocalCacheDriver.js index c5e4f30b0f4ed..6784a98e5f64d 100644 --- 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 index 96cb002e34947..98935f21a52c7 100644 --- 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() {