Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -1054,7 +1054,7 @@ mod test {
Err(_) => {}
_ => panic!(
"should be error: {}",
&headers.get("session_id").unwrap().as_ref().unwrap()
headers.get("session_id").unwrap().as_ref().unwrap()
),
}
}
Expand Down
4 changes: 2 additions & 2 deletions core/wren-core/core/src/logical_plan/analyze/plan.rs
Original file line number Diff line number Diff line change
Expand Up @@ -787,7 +787,7 @@ fn collect_model_required_fields(
return plan_err!("Only support calculated field with expression");
}
.alias(column.name.clone());
debug!("Required Calculated field: {}", &expr_plan);
debug!("Required Calculated field: {}", expr_plan);
required_fields
.entry(relation_ref.clone())
.or_default()
Expand All @@ -800,7 +800,7 @@ fn collect_model_required_fields(
Arc::clone(&session_state_ref),
Arc::clone(&session_properties),
)?;
debug!("Required field: {}", &expr_plan);
debug!("Required field: {}", expr_plan);
required_fields
.entry(relation_ref.clone())
.or_default()
Expand Down
2 changes: 1 addition & 1 deletion core/wren-core/core/src/mdl/cube.rs
Original file line number Diff line number Diff line change
Expand Up @@ -271,7 +271,7 @@ fn resolve_measures(
let mut sorted_deps = deps.clone();
sorted_deps.sort_by_key(|d| std::cmp::Reverse(d.len()));
for dep in sorted_deps {
let replacement = format!("({})", &resolved[dep]);
let replacement = format!("({})", resolved[dep]);
// NoExpand keeps `$1`, `$$tag$$` etc. literal — without it
// Regex::replace_all would treat them as capture-group templates
// and corrupt SQL expressions that contain `$`.
Expand Down
2 changes: 1 addition & 1 deletion core/wren-core/core/src/mdl/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -215,7 +215,7 @@ impl WrenMDL {
});
});
WrenMDL {
catalog_schema_prefix: format!("{}.{}.", &manifest.catalog, &manifest.schema),
catalog_schema_prefix: format!("{}.{}.", manifest.catalog, manifest.schema),
manifest,
qualified_references: qualifed_references,
register_tables: HashMap::new(),
Expand Down
2 changes: 1 addition & 1 deletion core/wren-core/sqllogictest/src/engine/normalize.rs
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ pub(crate) fn convert_batches(batches: Vec<RecordBatch>) -> Result<Vec<Vec<Strin
return Err(DFSqlLogicTestError::DataFusion(DataFusionError::Internal(
format!(
"Schema mismatch. Previously had\n{:#?}\n\nGot:\n{:#?}",
&schema,
schema,
batch.schema()
),
)));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,27 +87,27 @@ async fn main() -> datafusion::common::Result<()> {
println!("#####################");
println!(
"session_tenant_id: {}",
&properties
properties
.get("session_tenant_id")
.unwrap()
.clone()
.unwrap()
);
println!(
"session_department: {}",
&properties
properties
.get("session_department")
.unwrap()
.clone()
.unwrap()
);
println!(
"session_user_id: {}",
&properties.get("session_user_id").unwrap().clone().unwrap()
properties.get("session_user_id").unwrap().clone().unwrap()
);
println!(
"session_role: {}",
&properties.get("session_role").unwrap().clone().unwrap()
properties.get("session_role").unwrap().clone().unwrap()
);

let sql = "select * from wren.test.documents";
Expand Down
Loading