Skip to content

Commit 88ae09d

Browse files
committed
fix: ignore records before start timestamp
1 parent 318996f commit 88ae09d

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/bin/main.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,9 @@ async fn run() -> anyhow::Result<()> {
119119
receiver,
120120
fees_grt,
121121
} => {
122+
if aggregation_timestamp < start_timestamp {
123+
continue;
124+
}
122125
let key = IndexerFeesKey { signer, receiver };
123126
let agg = aggregations.entry(aggregation_timestamp).or_default();
124127
*agg.indexer_fees.entry(key).or_default() += fees_grt;

0 commit comments

Comments
 (0)