From c52bf5e1c2035ccf89a2968213601140662ba62b Mon Sep 17 00:00:00 2001 From: dal Date: Mon, 21 Apr 2025 13:42:47 -0600 Subject: [PATCH] remove limit on query restuls --- .../src/data_source_query_routes/snowflake_query.rs | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/api/libs/query_engine/src/data_source_query_routes/snowflake_query.rs b/api/libs/query_engine/src/data_source_query_routes/snowflake_query.rs index 6063cddbd..a9ca067d9 100644 --- a/api/libs/query_engine/src/data_source_query_routes/snowflake_query.rs +++ b/api/libs/query_engine/src/data_source_query_routes/snowflake_query.rs @@ -1493,12 +1493,7 @@ fn convert_array_to_datatype(column: &arrow::array::ArrayRef, field: &Field, row fn prepare_query(query: &str) -> String { const MAX_ROWS: usize = 1_000; - let query_no_semicolon = query.trim_end_matches(';'); - if !query_no_semicolon.to_lowercase().contains("limit") { - format!("{} FETCH FIRST {} ROWS ONLY", query_no_semicolon, MAX_ROWS) - } else { - query_no_semicolon.to_string() - } + query.to_string() } fn process_record_batch(batch: &RecordBatch) -> Vec> {