Skip to content
Draft
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 4 additions & 3 deletions sequencer/src/request_response/recipient_source.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,17 +46,18 @@ impl<I: NodeImplementation<SeqTypes>, V: Versions> RecipientSourceTrait<Request,
// Attempt to get the membership for the current epoch
let membership = match self
.memberships
.membership_for_epoch(Some(epoch_number))
.stake_table_for_epoch(Some(epoch_number))
.await
{
Ok(membership) => membership,
Err(e) => {
warn!(
"Failed to get membership for epoch {}: {e:#}. Failing over to genesis",
"Failed to get membership for epoch {}: {e:#}. Failing over to previous epoch",
epoch_number
);
let prev_epoch = epoch_number.saturating_sub(1);
self.memberships
.membership_for_epoch(Some(EpochNumber::genesis()))
.stake_table_for_epoch(Some(EpochNumber::new(prev_epoch)))
.await
.with_context(|| "failed to get stake table for epoch")?
},
Expand Down