Skip to content

Commit e6de89b

Browse files
committed
refactor(cubesql): Add explicit check for ungroupedness
1 parent bc582e5 commit e6de89b

File tree

1 file changed

+5
-0
lines changed
  • rust/cubesql/cubesql/src/compile/engine/df

1 file changed

+5
-0
lines changed

rust/cubesql/cubesql/src/compile/engine/df/wrapper.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -527,6 +527,11 @@ impl CubeScanWrapperNode {
527527
if let Some(cube_scan_node) =
528528
node.as_any().downcast_ref::<CubeScanNode>()
529529
{
530+
if cube_scan_node.request.ungrouped != Some(true) {
531+
return Err(CubeError::internal(format!(
532+
"Expected ungrouped CubeScan node but found: {cube_scan_node:?}"
533+
)));
534+
}
530535
Some(Arc::new(cube_scan_node.clone()))
531536
} else {
532537
return Err(CubeError::internal(format!(

0 commit comments

Comments
 (0)