Skip to content

Commit c29b491

Browse files
committed
adapter: avoid more tracing ref panics in explain codepaths
1 parent d421e90 commit c29b491

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

src/adapter/src/coord/sequencer/inner.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3434,6 +3434,7 @@ impl Coordinator {
34343434
&source_ids,
34353435
None, // no real-time recency
34363436
)
3437+
.with_subscriber(root_dispatch.clone())
34373438
.await?
34383439
.timestamp_context;
34393440

src/adapter/src/coord/sequencer/old_optimizer_api.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1024,6 +1024,7 @@ impl Coordinator {
10241024
&source_ids,
10251025
None, // no real-time recency
10261026
)
1027+
.with_subscriber(root_dispatch.clone())
10271028
.await?
10281029
.timestamp_context;
10291030

0 commit comments

Comments
 (0)