Skip to content

Commit d0d0ac8

Browse files
fix for get stream info API
1 parent 052c6de commit d0d0ac8

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

server/src/catalog.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -213,7 +213,7 @@ pub async fn remove_manifest_from_snapshot(
213213
) -> Result<Option<String>, ObjectStorageError> {
214214
match CONFIG.parseable.mode {
215215
Mode::All | Mode::Ingest => {
216-
if !dates[0].starts_with("1970") {
216+
if !dates.is_empty() {
217217
// get current snapshot
218218
let mut meta = storage.get_object_store_format(stream_name).await?;
219219
let manifests = &mut meta.snapshot.manifest_list;

server/src/handlers/http/logstream.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -560,7 +560,7 @@ pub async fn get_stream_info(req: HttpRequest) -> Result<impl Responder, StreamE
560560

561561
if first_event_at_empty(&stream_name) {
562562
let store = CONFIG.storage().get_object_store();
563-
let dates: Vec<String> = vec!["1970-01-01".to_string()];
563+
let dates: Vec<String> = Vec::new();
564564
if let Ok(Some(first_event_at)) = catalog::get_first_event(store, &stream_name, dates).await
565565
{
566566
if let Err(err) =

0 commit comments

Comments
 (0)