diff --git a/node/pkg/solana/client.go b/node/pkg/solana/client.go index 7642595c1..ade4df0a7 100644 --- a/node/pkg/solana/client.go +++ b/node/pkg/solana/client.go @@ -128,7 +128,7 @@ func (s *SolanaWatcher) Run(ctx context.Context) error { var recovery <-chan time.Time date := recoveryDate.Sub(time.Now().UTC()) - if date >= 0 { + if date >= 0 && s.commitment == rpc.CommitmentFinalized { logger.Info("waiting for scheduled recovery", zap.Duration("until", date)) recovery = time.NewTimer(date).C } else {