Skip to content

Commit 587da4b

Browse files
committed
Include the filter, pagination in the aggregation request
1 parent 009045f commit 587da4b

File tree

1 file changed

+5
-5
lines changed
  • crates/connectors/ndc-calcite/src

1 file changed

+5
-5
lines changed

crates/connectors/ndc-calcite/src/sql.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -921,12 +921,12 @@ pub fn parse_query<'a>(
921921

922922
query_components.select = Some(select_clause.join(","));
923923
query_components.join = join_clause;
924-
query_components.variables_cte = variables_cte;
925-
926-
query_components.order_by = Some(order_by(query).join(", "));
927-
query_components.pagination = Some(pagination(query).join(" "));
928-
query_components.predicates = Some(predicates);
929924
}
930925

926+
query_components.order_by = Some(order_by(query).join(", "));
927+
query_components.pagination = Some(pagination(query).join(" "));
928+
query_components.predicates = Some(predicates);
929+
query_components.variables_cte = variables_cte;
930+
931931
Ok(query_components)
932932
}

0 commit comments

Comments
 (0)