fix ci

fix ci fmt
risingwavelabs · Jun 6, 2024 · d940439 · d940439
1 parent 5195a4e
commit d940439
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 18 deletions.
diff --git a/src/frontend/src/binder/mod.rs b/src/frontend/src/binder/mod.rs
@@ -574,22 +574,24 @@ mod tests {
                                 Share(
                                     BoundShare {
                                         share_id: 0,
-                                        input: Right(
-                                            RecursiveUnion {
-                                                all: true,
-                                                base: Select(
-                                                    BoundSelect {
-                                                        distinct: All,
-                                                        select_items: [
-                                                            Literal(
-                                                                Literal {
-                                                                    data: Some(
-                                                                        Int32(
-                                                                            1,
+                                        input: Query(
+                                            Right(
+                                                RecursiveUnion {
+                                                    all: true,
+                                                    base: Select(
+                                                        BoundSelect {
+                                                            distinct: All,
+                                                            select_items: [
+                                                                Literal(
+                                                                    Literal {
+                                                                        data: Some(
+                                                                            Int32(
+                                                                                1,
+                                                                            ),
+                                                                        ),
+                                                                        data_type: Some(
+                                                                            Int32,
                                                                         ),
-                                                                    ),
-                                                                    data_type: Some(
-                                                                        Int32,
                                                                     ),
                                                                 },
                                                             ),

diff --git a/src/frontend/src/optimizer/plan_node/logical_changed_log.rs b/src/frontend/src/optimizer/plan_node/logical_changed_log.rs
@@ -14,13 +14,13 @@
 
 use super::expr_visitable::ExprVisitable;
 use super::generic::GenericPlanRef;
-use crate::error::ErrorCode::BindError;
 use super::utils::impl_distill_by_unit;
 use super::{
     gen_filter_and_pushdown, generic, ColPrunable, ColumnPruningContext, ExprRewritable, Logical,
     PlanBase, PlanTreeNodeUnary, PredicatePushdown, RewriteStreamContext, StreamChangedLog,
     StreamRowIdGen, ToBatch, ToStream, ToStreamContext,
 };
+use crate::error::ErrorCode::BindError;
 use crate::error::Result;
 use crate::optimizer::property::Distribution;
 use crate::utils::{ColIndexMapping, Condition};

diff --git a/src/sqlparser/tests/sqlparser_common.rs b/src/sqlparser/tests/sqlparser_common.rs
@@ -2690,7 +2690,7 @@ fn parse_ctes() {
     fn assert_ctes_in_select(expected: &[&str], sel: &Query) {
         for (i, exp) in expected.iter().enumerate() {
             let Cte { alias, query, .. } = &sel.with.as_ref().unwrap().cte_tables[i];
-            assert_eq!(*exp, query.to_string());
+            assert_eq!(*exp, query.as_ref().unwrap().to_string());
             assert_eq!(
                 if i == 0 {
                     Ident::new_unchecked("a")
@@ -2732,7 +2732,13 @@ fn parse_ctes() {
     // CTE in a CTE...
     let sql = &format!("WITH outer_cte AS ({}) SELECT * FROM outer_cte", with);
     let select = verified_query(sql);
-    assert_ctes_in_select(&cte_sqls, &only(&select.with.unwrap().cte_tables).query);
+    assert_ctes_in_select(
+        &cte_sqls,
+        only(&select.with.unwrap().cte_tables)
+            .query
+            .as_ref()
+            .unwrap(),
+    );
 }
 
 #[test]