Skip to content

Commit 848e175

Browse files
committed
fix clippy and fmt
1 parent badcdb6 commit 848e175

File tree

2 files changed

+12
-8
lines changed

2 files changed

+12
-8
lines changed

datafusion/expr/Cargo.toml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,6 @@ paste = "^1.0"
5454
recursive = { workspace = true, optional = true }
5555
serde_json = { workspace = true }
5656
sqlparser = { workspace = true }
57-
async-trait = "0.1.86"
5857

5958
[dev-dependencies]
6059
ctor = { workspace = true }

datafusion/physical-plan/src/async_func.rs

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -108,15 +108,20 @@ impl DisplayAs for AsyncFuncExec {
108108
t: DisplayFormatType,
109109
f: &mut std::fmt::Formatter,
110110
) -> std::fmt::Result {
111+
let expr: Vec<String> = self
112+
.async_exprs
113+
.iter()
114+
.map(|async_expr| async_expr.to_string())
115+
.collect();
116+
let exprs = expr.join(", ");
111117
match t {
112118
DisplayFormatType::Default | DisplayFormatType::Verbose => {
113-
let expr: Vec<String> = self
114-
.async_exprs
115-
.iter()
116-
.map(|async_expr| async_expr.to_string())
117-
.collect();
118-
119-
write!(f, "AsyncFuncExec: async_expr=[{}]", expr.join(", "))
119+
write!(f, "AsyncFuncExec: async_expr=[{}]", exprs)
120+
}
121+
DisplayFormatType::TreeRender => {
122+
writeln!(f, "format=async_expr")?;
123+
writeln!(f, "async_expr={}", exprs)?;
124+
Ok(())
120125
}
121126
}
122127
}

0 commit comments

Comments
 (0)