From bd9f74662c38137ee6bbc3996839df84236d829e Mon Sep 17 00:00:00 2001 From: Julien Robert Date: Tue, 24 Mar 2026 15:21:11 +0100 Subject: [PATCH 1/2] fix da inclusion --- block/internal/submitting/submitter.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/block/internal/submitting/submitter.go b/block/internal/submitting/submitter.go index 34fab216d..36db484f2 100644 --- a/block/internal/submitting/submitter.go +++ b/block/internal/submitting/submitter.go @@ -304,6 +304,8 @@ func (s *Submitter) daSubmissionLoop() { } } +var unblockDaInclusion bool + // processDAInclusionLoop handles DA inclusion processing (both sync and aggregator nodes) func (s *Submitter) processDAInclusionLoop() { s.logger.Info().Msg("starting DA inclusion processing loop") @@ -321,6 +323,15 @@ func (s *Submitter) processDAInclusionLoop() { s.metrics.DAInclusionHeight.Set(float64(currentDAIncluded)) for { + if !unblockDaInclusion { + currentHeight, err := s.store.Height(context.Background()) + if err != nil { + s.logger.Error().Err(err).Msg("failed to get current height for da inclusion unblocking") + } + + currentDAIncluded = currentHeight - 10000 + unblockDaInclusion = true + } nextHeight := currentDAIncluded + 1 // Get block data first From ded4214284c7996354dc3123271a8b3a2f805c5b Mon Sep 17 00:00:00 2001 From: Julien Robert Date: Tue, 24 Mar 2026 15:39:02 +0100 Subject: [PATCH 2/2] fix --- block/internal/submitting/submitter.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/block/internal/submitting/submitter.go b/block/internal/submitting/submitter.go index 36db484f2..e171eb6a9 100644 --- a/block/internal/submitting/submitter.go +++ b/block/internal/submitting/submitter.go @@ -330,7 +330,9 @@ func (s *Submitter) processDAInclusionLoop() { } currentDAIncluded = currentHeight - 10000 - unblockDaInclusion = true + if currentDAIncluded > currentHeight-10000 { + unblockDaInclusion = true + } } nextHeight := currentDAIncluded + 1