Skip to content

Commit 9246d4a

Browse files
committed
fix TestEvmBasedSequencerBaselineE2E
1 parent dd996f0 commit 9246d4a

2 files changed

Lines changed: 9 additions & 4 deletions

File tree

block/internal/da/forced_inclusion_retriever.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -232,6 +232,7 @@ func (r *forcedInclusionRetriever) RetrieveForcedIncludedTxs(ctx context.Context
232232
Msg("Failed to retrieve DA epoch.. retrying next iteration")
233233

234234
return &ForcedInclusionEvent{
235+
Timestamp: event.Timestamp,
235236
StartDaHeight: daHeight,
236237
EndDaHeight: daHeight,
237238
Txs: [][]byte{},

pkg/sequencers/based/sequencer.go

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -49,9 +49,10 @@ func NewBasedSequencer(
4949
executor execution.Executor,
5050
) (*BasedSequencer, error) {
5151
bs := &BasedSequencer{
52-
logger: logger.With().Str("component", "based_sequencer").Logger(),
53-
checkpointStore: seqcommon.NewCheckpointStore(db, ds.NewKey("/based/checkpoint")),
54-
executor: executor,
52+
logger: logger.With().Str("component", "based_sequencer").Logger(),
53+
checkpointStore: seqcommon.NewCheckpointStore(db, ds.NewKey("/based/checkpoint")),
54+
executor: executor,
55+
currentDAEndTime: genesis.StartTime,
5556
}
5657
// based sequencers need community consensus about the da start height given no submission are done
5758
bs.SetDAHeight(genesis.DAStartHeight)
@@ -108,7 +109,10 @@ func (s *BasedSequencer) GetNextBatch(ctx context.Context, req coresequencer.Get
108109
return nil, err
109110
}
110111
daHeight = daEndHeight
111-
s.currentDAEndTime = daEndTime
112+
113+
if daEndTime.After(s.currentDAEndTime) {
114+
s.currentDAEndTime = daEndTime
115+
}
112116
}
113117

114118
// Get remaining transactions from checkpoint position

0 commit comments

Comments
 (0)