Skip to content

Commit 09316cf

Browse files
authored
Merge branch 'master' into returnUsedPreAggregation
2 parents 7bb9400 + ee826e1 commit 09316cf

File tree

2 files changed

+10
-3
lines changed

2 files changed

+10
-3
lines changed

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

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -347,10 +347,13 @@ impl TransportService for NodeBridgeTransport {
347347
.map(|s| s.span_id.clone())
348348
.unwrap_or_else(|| Uuid::new_v4().to_string());
349349

350+
let mut req_seq_id: u32 = 0;
351+
350352
loop {
353+
req_seq_id += 1;
351354
let extra = serde_json::to_string(&LoadRequest {
352355
request: TransportRequest {
353-
id: format!("{}-span-{}", request_id, 1),
356+
id: format!("{}-span-{}", request_id, req_seq_id),
354357
meta: Some(meta.clone()),
355358
},
356359
query: query.clone(),
@@ -433,15 +436,19 @@ impl TransportService for NodeBridgeTransport {
433436
.as_ref()
434437
.map(|s| s.span_id.clone())
435438
.unwrap_or_else(|| Uuid::new_v4().to_string());
439+
440+
let mut req_seq_id: u32 = 0;
441+
436442
loop {
443+
req_seq_id += 1;
437444
let native_auth = ctx
438445
.as_any()
439446
.downcast_ref::<NativeAuthContext>()
440447
.expect("Unable to cast AuthContext to NativeAuthContext");
441448

442449
let extra = serde_json::to_string(&LoadRequest {
443450
request: TransportRequest {
444-
id: format!("{}-span-{}", request_id, 1),
451+
id: format!("{}-span-{}", request_id, req_seq_id),
445452
meta: Some(meta.clone()),
446453
},
447454
query: query.clone(),

packages/cubejs-dremio-driver/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
},
3232
"devDependencies": {
3333
"@cubejs-backend/linter": "^1.0.0",
34-
"@cubejs-backend/testing-shared": "1.1.9",
34+
"@cubejs-backend/testing-shared": "1.1.11",
3535
"jest": "^27"
3636
},
3737
"license": "Apache-2.0",

0 commit comments

Comments
 (0)