Skip to content

Commit ca0f992

Browse files
committed
temp comment append
1 parent 576b71a commit ca0f992

1 file changed

Lines changed: 6 additions & 7 deletions

File tree

block/internal/syncing/syncer.go

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@ import (
1111

1212
goheader "github.com/celestiaorg/go-header"
1313
"github.com/rs/zerolog"
14-
"golang.org/x/sync/errgroup"
1514

1615
"github.com/evstack/ev-node/block/internal/cache"
1716
"github.com/evstack/ev-node/block/internal/common"
@@ -406,12 +405,12 @@ func (s *Syncer) processHeightEvent(event *common.DAHeightEvent) {
406405

407406
// only save to p2p stores if the event came from DA
408407
if event.Source == common.SourceDA {
409-
g, ctx := errgroup.WithContext(s.ctx)
410-
g.Go(func() error { return s.headerStore.Append(ctx, event.Header) })
411-
g.Go(func() error { return s.dataStore.Append(ctx, event.Data) })
412-
if err := g.Wait(); err != nil {
413-
s.logger.Error().Err(err).Msg("failed to append event header and/or data to p2p store")
414-
}
408+
// g, ctx := errgroup.WithContext(s.ctx)
409+
// g.Go(func() error { return s.headerStore.Append(ctx, event.Header) })
410+
// g.Go(func() error { return s.dataStore.Append(ctx, event.Data) })
411+
// if err := g.Wait(); err != nil {
412+
// s.logger.Error().Err(err).Msg("failed to append event header and/or data to p2p store")
413+
// }
415414
}
416415
}
417416

0 commit comments

Comments
 (0)