Skip to content

Commit 1d6a7f0

Browse files
Fixes
1 parent 3d8216b commit 1d6a7f0

4 files changed

Lines changed: 10 additions & 4 deletions

File tree

.claude/settings.local.json

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,10 @@
1414
"Bash(cargo search:*)",
1515
"Bash(cargo info:*)",
1616
"Bash(cargo build:*)",
17-
"Bash(cargo doc:*)"
17+
"Bash(cargo doc:*)",
18+
"Bash(RUST_BACKTRACE=1 cargo test:*)",
19+
"Bash(cargo run:*)",
20+
"Bash(RUST_LOG=debug cargo run:*)"
1821
],
1922
"deny": [],
2023
"ask": []

crates/datafusion-app/src/config.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ pub fn merge_configs(shared: ExecutionConfig, priority: ExecutionConfig) -> Exec
6363
// }
6464

6565
#[cfg(feature = "udfs-wasm")]
66-
if merged.wasm_udf != priority.wasm_udf {
66+
if !priority.wasm_udf.module_functions.is_empty() {
6767
merged.wasm_udf = priority.wasm_udf
6868
}
6969

src/db.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,10 @@ fn detect_format(extension: &str) -> Result<(Arc<dyn FileFormat>, &'static str)>
4040
"csv" => Ok((Arc::new(CsvFormat::default()), ".csv")),
4141
"json" => Ok((Arc::new(JsonFormat::default()), ".json")),
4242
#[cfg(feature = "vortex")]
43-
"vortex" => Ok((Arc::new(VortexFormat::new(VortexSession::empty())), ".vortex")),
43+
"vortex" => Ok((
44+
Arc::new(VortexFormat::new(VortexSession::empty())),
45+
".vortex",
46+
)),
4447
_ => Err(Report::msg(format!(
4548
"Unsupported file extension: {}",
4649
extension

tests/config.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ impl TestConfigBuilder {
127127
return_type: &str,
128128
) -> &mut Self {
129129
// Begin the wasm UDF section.
130-
self.config_text.push_str("[execution.wasm_udf]\n");
130+
self.config_text.push_str("[shared.wasm_udf]\n");
131131

132132
// Start the inline table for module_functions.
133133
self.config_text.push_str("module_functions = { ");

0 commit comments

Comments
 (0)