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 f26536b commit d8e9fa1Copy full SHA for d8e9fa1
block/internal/syncing/syncer.go
@@ -299,13 +299,7 @@ func (s *Syncer) fetchDAUntilCaughtUp() error {
299
300
daHeight := s.GetDAHeight()
301
302
- // Create a cancellable context for the DA call that inherits the syncer's lifecycle.
303
- // We intentionally avoid adding another timeout layer on top of the per-request timeout
304
- // inside the DA retriever so large blob batches can finish downloading.
305
- ctx, cancel := context.WithCancel(s.ctx)
306
-
307
- events, err := s.daRetriever.RetrieveFromDA(ctx, daHeight)
308
- cancel()
+ events, err := s.daRetriever.RetrieveFromDA(s.ctx, daHeight)
309
if err != nil {
310
switch {
311
case errors.Is(err, coreda.ErrBlobNotFound):
0 commit comments