Skip to content
Snippets Groups Projects
Commit 6620fbe4 authored by Phil Höfer's avatar Phil Höfer
Browse files

Reduce Initial Query Ingest

parent 44794538
No related branches found
No related tags found
No related merge requests found
Pipeline #10073 passed
......@@ -176,7 +176,7 @@ fn read_from_db(config: HashMap<String, String>, predictor: &mut CompositePredic
match client {
Ok(mut c) => {
let mut count = 0;
match c.query("SELECT query FROM public.logs_partitioned ORDER BY time DESC LIMIT 100000", &[]) {
match c.query("SELECT query FROM public.logs_partitioned ORDER BY time DESC LIMIT 1000", &[]) {
Ok(rows) => {
for row in rows {
let query: &str = row.get(0);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment