We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9673004 commit 699cadfCopy full SHA for 699cadf
1 file changed
block/internal/syncing/syncer.go
@@ -303,7 +303,12 @@ func (s *Syncer) fetchDAUntilCaughtUp() error {
303
}
304
305
daHeight := s.GetDAHeight()
306
- events, err := s.daRetriever.RetrieveFromDA(s.ctx, daHeight)
+
307
+ // Create a new context with a timeout for the DA call
308
+ ctx, cancel := context.WithTimeout(s.ctx, 5*time.Second)
309
+ defer cancel()
310
311
+ events, err := s.daRetriever.RetrieveFromDA(ctx, daHeight)
312
if err != nil {
313
switch {
314
case errors.Is(err, coreda.ErrBlobNotFound):
0 commit comments