chore: fix

Author: ovr

packages/cubejs-backend-native/src/orchestrator.rs

@@ -1,10 +1,8 @@
 use crate::node_obj_deserializer::JsValueDeserializer;
 use crate::transport::MapCubeErrExt;
 use cubeorchestrator::query_message_parser::QueryResult;
-use cubeorchestrator::query_result_transform::{
-    DBResponsePrimitive, DBResponseValue, RequestResultData, RequestResultDataMulti,
-    TransformedData,
-};
+use cubeorchestrator::query_result_transform::{DBResponsePrimitive, DBResponseValue, RequestResultData, RequestResultDataMulti,
+    TransformedData};
 use cubeorchestrator::transport::{JsRawData, TransformDataRequest};
 use cubesql::compile::engine::df::scan::{FieldValue, ValueObject};
 use cubesql::CubeError;
@@ -259,12 +257,12 @@ pub fn get_cubestore_result(mut cx: FunctionContext) -> JsResult<JsValue> {
                 let js_row = JsObject::new(&mut cx);
                 for (key, value) in result.columns.iter().zip(row.iter()) {
                     let js_key = cx.string(key);
+
                     let js_value: Handle<'_, JsValue> = match value {
                         DBResponseValue::Primitive(DBResponsePrimitive::Null) => cx.null().upcast(),
                         // For compatibility, we convert all primitives to strings
                         other => cx.string(other.to_string()).upcast(),
                     };
-
                     js_row.set(&mut cx, js_key, js_value)?;
                 }
                 Ok(js_row)

packages/cubejs-cubestore-driver/src/CubeStoreQueueDriver.ts

@@ -252,6 +252,9 @@ class CubestoreQueueDriverConnection implements QueueDriverConnectionInterface {
     const payload = JSON.parse(row.payload);
 
     if (row.extra) {
+      console.log(row.extra, typeof row.extra);
+      console.log(payload, typeof payload);
+      console.log(row.payload, typeof row.payload);
       return Object.assign(payload, JSON.parse(row.extra));
     }
 

packages/cubejs-query-orchestrator/test/benchmarks/QueueBench.abstract.ts

@@ -138,6 +138,10 @@ export function QueryQueueBenchmark(name: string, options: QueryQueueTestOptions
           } else {
             counters.events[event] = 1;
           }
+
+          if (event.includes('error')) {
+            console.log(event, _params);
+          }
         },
         queueDriverFactory,
         ...options
@@ -159,7 +163,8 @@ export function QueryQueueBenchmark(name: string, options: QueryQueueTestOptions
       const progressIntervalId = setInterval(() => {
         console.log('running', {
           ...counters,
-          processingPromisses: processingPromisses.length
+          processingPromisses: processingPromisses.length,
+          benchSettings,
         });
       }, 1000);
 
@@ -177,18 +182,25 @@ export function QueryQueueBenchmark(name: string, options: QueryQueueTestOptions
 
         const queueId = crypto.randomBytes(12).toString('hex');
         const running = (async () => {
-          await queue.executeInQueue('query', queueId, {
-            // eslint-disable-next-line no-bitwise
-            payload: 'a'.repeat(benchSettings.queuePayloadSize)
-          }, 1, {
+          try {
+            await queue.executeInQueue('query', queueId, {
+              // eslint-disable-next-line no-bitwise
+              payload: {
+                large_str: 'a'.repeat(benchSettings.queuePayloadSize)
+              },
+              orphanedTimeout: 120
+            }, 1, {
             stageQueryKey: 1,
             requestId: 'request-id',
             spanId: 'span-id'
-          });
+            });
+          } catch (e) {
+            console.error(e);
+          }
 
           counters.queueResolved++;
 
-          // loosing memory for result
+          // losing memory for a result
           return null;
         })();