Skip to content

Commit 6a621ce

Browse files
Fix TPCDS runner explain analyze await (datafusion-contrib#442)
## Summary Fixes the `console/examples/tpcds_runner.rs` example after `explain_analyze` became async. ## Validation - `cargo test --workspace`
1 parent dea27a9 commit 6a621ce

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

console/examples/tpcds_runner.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,8 @@ async fn run_single_query(
189189
let batches = stream.try_collect::<Vec<_>>().await?;
190190
if explain_analyze {
191191
let output =
192-
datafusion_distributed::explain_analyze(plan, DistributedMetricsFormat::Aggregated)?;
192+
datafusion_distributed::explain_analyze(plan, DistributedMetricsFormat::Aggregated)
193+
.await?;
193194
println!("{output}");
194195
}
195196
Ok(batches)

0 commit comments

Comments
 (0)