feat: Add refreshKeyRenewalThreshold option

Fixes #112
cube-js · May 22, 2019 · aa69449 · aa69449
1 parent 4426e00
commit aa69449
Showing 1 changed file with 7 additions and 9 deletions.
diff --git a/packages/cubejs-query-orchestrator/orchestrator/QueryCache.js b/packages/cubejs-query-orchestrator/orchestrator/QueryCache.js
@@ -174,15 +174,13 @@ class QueryCache {
   renewQuery(query, values, cacheKeyQueries, expireSecs, cacheKey, renewalThreshold, options) {
     options = options || {};
     return Promise.all(
-      cacheKeyQueries.map(q =>
-        this.cacheQueryResult(
-          Array.isArray(q) ? q[0] : q,
-          Array.isArray(q) ? q[1] : [],
-          q,
-          expireSecs,
-          { renewalThreshold: 2 * 60, renewalKey: q, waitForRenew: true }
-        )
-      )
+      cacheKeyQueries.map(q => this.cacheQueryResult(
+        Array.isArray(q) ? q[0] : q,
+        Array.isArray(q) ? q[1] : [],
+        q,
+        expireSecs,
+        { renewalThreshold: this.options.refreshKeyRenewalThreshold || 2 * 60, renewalKey: q, waitForRenew: true }
+      ))
     )
       .catch(e => {
         if (e instanceof ContinueWaitError) {