Skip to content

Commit

Permalink
Remove unnecessary async
Browse files Browse the repository at this point in the history
  • Loading branch information
matthewmturner committed Feb 9, 2022
1 parent 2fc3413 commit 33aebb6
Showing 1 changed file with 4 additions and 7 deletions.
11 changes: 4 additions & 7 deletions datafusion/tests/path_partition.rs
Original file line number Diff line number Diff line change
Expand Up @@ -49,8 +49,7 @@ async fn csv_filter_with_file_col() -> Result<()> {
],
&["date"],
"mytable",
)
.await;
);

let result = ctx
.sql("SELECT c1, c2 FROM t WHERE date='2021-10-27' and date!=c1 LIMIT 5")
Expand Down Expand Up @@ -86,8 +85,7 @@ async fn csv_projection_on_partition() -> Result<()> {
],
&["date"],
"mytable",
)
.await;
);

let result = ctx
.sql("SELECT c1, date FROM t WHERE date='2021-10-27' LIMIT 5")
Expand Down Expand Up @@ -124,8 +122,7 @@ async fn csv_grouping_by_partition() -> Result<()> {
],
&["date"],
"mytable",
)
.await;
);

let result = ctx
.sql("SELECT date, count(*), count(distinct(c1)) FROM t WHERE date<='2021-10-27' GROUP BY date")
Expand Down Expand Up @@ -274,7 +271,7 @@ async fn parquet_overlapping_columns() -> Result<()> {
Ok(())
}

async fn register_partitioned_aggregate_csv(
fn register_partitioned_aggregate_csv(
ctx: &mut ExecutionContext,
store_paths: &[&str],
partition_cols: &[&str],
Expand Down

0 comments on commit 33aebb6

Please sign in to comment.