We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fc2ae64 commit 191298bCopy full SHA for 191298b
internal/orchestrator/committer.go
@@ -111,7 +111,7 @@ func (c *Committer) Start(ctx context.Context) {
111
Str("latest_committed", latestCommittedBlockNumber.String()).
112
Str("gap", gap.String()).
113
Msg("Publisher is behind committed position, seeking forward to committed value")
114
-
+
115
c.lastPublishedBlock.Store(latestCommittedBlockNumber.Uint64())
116
if err := c.storage.StagingStorage.SetLastPublishedBlockNumber(chainID, latestCommittedBlockNumber); err != nil {
117
log.Error().Err(err).Msg("Failed to update last published block number after seeking forward")
0 commit comments