Remove to_position_inclusive parameter from fetch stream (#4128)

quickwit-oss · Nov 14, 2023 · 4feca08 · 4feca08
1 parent 443be6e
commit 4feca08
Show file tree

Hide file tree

Showing 6 changed files with 133 additions and 217 deletions.
diff --git a/quickwit/quickwit-indexing/src/source/ingest/mod.rs b/quickwit/quickwit-indexing/src/source/ingest/mod.rs
@@ -409,7 +409,6 @@ impl Source for IngestSource {
                 .publish_position_inclusive
                 .unwrap_or_default();
             let from_position_exclusive = current_position_inclusive.clone();
-            let to_position_inclusive = Position::Eof;
 
             let status = if from_position_exclusive == Position::Eof {
                 IndexingStatus::Complete
@@ -421,7 +420,6 @@ impl Source for IngestSource {
                     source_id,
                     shard_id,
                     from_position_exclusive,
-                    to_position_inclusive,
                 ))
                 .await
             {