Skip to content

Commit 67c6cfc

Browse files
committed
fix: aggregator idempotency
restart from the beginning of conclusion events to avoid skipping on restarts. need to figure out why memory table contains conclusion_event_order that is less than the data written to event_states still, and hopefully restart where we left off. for now, we just ignore things we've seen before.
1 parent c64249c commit 67c6cfc

5 files changed

Lines changed: 446 additions & 86 deletions

File tree

Cargo.lock

Lines changed: 2 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

pipeline/Cargo.toml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,3 +52,5 @@ url.workspace = true
5252
mockall.workspace = true
5353
test-log.workspace = true
5454
tracing-subscriber.workspace = true
55+
rand.workspace = true
56+
multihash-codetable.workspace = true

0 commit comments

Comments
 (0)