Skip to content

Commit deab7f7

Browse files
committed
fix duplicate inserts
1 parent 8322feb commit deab7f7

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

internal/orchestrator/committer.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -47,16 +47,15 @@ func NewCommitter(rpc rpc.IRPCClient, storage storage.IStorage) *Committer {
4747

4848
func (c *Committer) Start(ctx context.Context) {
4949
interval := time.Duration(c.triggerIntervalMs) * time.Millisecond
50-
ticker := time.NewTicker(interval)
51-
defer ticker.Stop()
5250

5351
log.Debug().Msgf("Committer running")
5452
for {
5553
select {
5654
case <-ctx.Done():
5755
log.Info().Msg("Committer shutting down")
5856
return
59-
case <-ticker.C:
57+
default:
58+
time.Sleep(interval)
6059
blockDataToCommit, err := c.getSequentialBlockDataToCommit()
6160
if err != nil {
6261
log.Error().Err(err).Msg("Error getting block data to commit")

0 commit comments

Comments
 (0)