Skip to content

Commit 2816b5d

Browse files
more cleanup
1 parent 1ac06b6 commit 2816b5d

3 files changed

Lines changed: 17 additions & 8 deletions

File tree

src/cli/mod.rs

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,8 @@ use datafusion::arrow::datatypes::SchemaRef;
2525
use datafusion::arrow::util::pretty::pretty_format_batches;
2626
use datafusion::arrow::{csv, json};
2727
use datafusion::sql::parser::DFParser;
28-
use datafusion_app::config::{merge_configs, AuthConfig, FlightSQLConfig};
28+
use datafusion_app::config::merge_configs;
2929
use datafusion_app::extensions::DftSessionStateBuilder;
30-
use datafusion_app::flightsql::FlightSQLContext;
3130
use datafusion_app::local::ExecutionContext;
3231
use datafusion_app::local_benchmarks::LocalBenchmarkStats;
3332
use futures::{Stream, StreamExt};
@@ -38,7 +37,14 @@ use std::fs::File;
3837
use std::io::Write;
3938
use std::path::{Path, PathBuf};
4039
#[cfg(feature = "flightsql")]
41-
use {datafusion_app::flightsql_benchmarks::FlightSQLBenchmarkStats, tonic::IntoRequest};
40+
use {
41+
datafusion_app::{
42+
config::{AuthConfig, FlightSQLConfig},
43+
flightsql::FlightSQLContext,
44+
flightsql_benchmarks::FlightSQLBenchmarkStats,
45+
},
46+
tonic::IntoRequest,
47+
};
4248

4349
const LOCAL_BENCHMARK_HEADER_ROW: &str =
4450
"query,runs,logical_planning_min,logical_planning_max,logical_planning_mean,logical_planning_median,logical_planning_percent_of_total,physical_planning_min,physical_planning_max,physical_planning,mean,physical_planning_median,physical_planning_percent_of_total,execution_min,execution_max,execution_execution_mean,execution_median,execution_percent_of_total,total_min,total_max,total_mean,total_median,total_percent_of_total";

src/main.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,9 @@
1717

1818
use clap::Parser;
1919
use color_eyre::Result;
20-
use datafusion_dft::args::Command;
21-
use datafusion_dft::{args::DftArgs, cli, config::create_config, flightsql_server, tui};
20+
#[cfg(feature = "flightsql")]
21+
use datafusion_dft::{args::Command, flightsql_server};
22+
use datafusion_dft::{args::DftArgs, cli, config::create_config, tui};
2223

2324
fn main() -> Result<()> {
2425
let cli = DftArgs::parse();

tests/tui_cases/quit.rs

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,9 @@
2020
use datafusion_app::extensions::DftSessionStateBuilder;
2121
use datafusion_app::local::ExecutionContext;
2222
use datafusion_dft::args::DftArgs;
23+
use datafusion_dft::config::create_config;
2324
use datafusion_dft::execution::AppExecution;
24-
use datafusion_dft::tui::state::initialize;
25+
use datafusion_dft::tui::state::AppState;
2526
use datafusion_dft::tui::{App, AppEvent};
2627
use ratatui::crossterm::event;
2728
use tempfile::{tempdir, TempDir};
@@ -102,11 +103,12 @@ struct TestApp<'app> {
102103
app: App<'app>,
103104
}
104105

105-
impl<'app> TestApp<'app> {
106+
impl TestApp<'_> {
106107
/// Create a new [`TestApp`] instance configured with a temporary directory
107108
async fn new() -> Self {
108109
let config_path = tempdir().unwrap();
109-
let state = initialize(config_path.path().to_path_buf());
110+
let config = create_config(config_path.path().to_path_buf());
111+
let state = AppState::new(config);
110112

111113
let session_state =
112114
DftSessionStateBuilder::try_new(Some(state.config.tui.execution.clone()))

0 commit comments

Comments
 (0)