Skip to content

Commit 935b9cf

Browse files
simplify
1 parent 7ee906e commit 935b9cf

File tree

1 file changed

+3
-9
lines changed

1 file changed

+3
-9
lines changed

src/storage/object_storage.rs

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -899,15 +899,9 @@ pub trait ObjectStorage: Debug + Send + Sync + 'static {
899899
let first_timestamp = self
900900
.extract_timestamp_for_date(stream_name, min_date, true)
901901
.await?;
902-
let latest_timestamp = if min_date == max_date {
903-
// Same date, get max timestamp from the same date
904-
self.extract_timestamp_for_date(stream_name, max_date, false)
905-
.await?
906-
} else {
907-
// Different dates, get max from the latest date
908-
self.extract_timestamp_for_date(stream_name, max_date, false)
909-
.await?
910-
};
902+
let latest_timestamp = self
903+
.extract_timestamp_for_date(stream_name, max_date, false)
904+
.await?;
911905

912906
let first_event_at = first_timestamp.map(|ts| ts.to_rfc3339());
913907
let latest_event_at = latest_timestamp.map(|ts| ts.to_rfc3339());

0 commit comments

Comments
 (0)