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

Comparing version 0.19.6 to 0.19.7

CHANGELOG.md

@@ -6,2 +6,13 @@ # Change Log
 
+## [0.19.7](https://github.com/cube-js/cube.js/compare/v0.19.6...v0.19.7) (2020-04-14)
+
+
+### Bug Fixes
+
+* Associate Queue storage error with requestId ([ec2750e](https://github.com/cube-js/cube.js/commit/ec2750e))
+
+
+
+
+
 ## [0.19.6](https://github.com/cube-js/cube.js/compare/v0.19.5...v0.19.6) (2020-04-14)
@@ -8,0 +19,0 @@

orchestrator/QueryQueue.js

@@ -211,6 +211,12 @@ const R = require('ramda');
     const redisClient = await this.queueDriver.createConnection();
+    let insertedCount;
+    // eslint-disable-next-line no-unused-vars
+    let removedCount;
+    let activeKeys;
+    let queueSize;
+    let query;
+    let processingLockAcquired;
     try {
       const processingId = await redisClient.getNextProcessingId();
-      // eslint-disable-next-line no-unused-vars
-      const [insertedCount, removedCount, activeKeys, queueSize, query, processingLockAcquired] =
+      [insertedCount, removedCount, activeKeys, queueSize, query, processingLockAcquired] =
         await redisClient.retrieveForProcessing(queryKey, processingId);
@@ -321,3 +327,4 @@ if (query && insertedCount && activeKeys.indexOf(this.redisHash(queryKey)) !== -1 && processingLockAcquired) {
       this.logger('Queue storage error', {
-        queryKey,
+        queryKey: query && query.queryKey || queryKey,
+        requestId: query && query.requestId,
         error: (e.stack || e).toString(),
@@ -324,0 +331,0 @@ queuePrefix: this.redisQueuePrefix

package.json

@@ -5,3 +5,3 @@ {
   "author": "Statsbot, Inc.",
-  "version": "0.19.6",
+  "version": "0.19.7",
   "repository": {
@@ -29,3 +29,3 @@ "type": "git",
   "license": "Apache-2.0",
-  "gitHead": "ed23d4e1dcfd209ee86cf1d604a7567b2efd23d3"
+  "gitHead": "4d0aa40285ac2f8003102ec95100cbbfa0b8ce62"
 }

No alert changes

Improved metrics

Total package byte prevSize

168136

increased by0.25%

Lines of code

2429

increased by0.29%

No dependency changes