Skip to content

Commit 4f18a4d

Browse files
committed
fix: use existing retry function
1 parent e89faed commit 4f18a4d

1 file changed

Lines changed: 8 additions & 6 deletions

File tree

pkg/timelock/worker_solana.go

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@ import (
99
"syscall"
1010
"time"
1111

12-
"github.com/cenkalti/backoff/v4"
1312
"github.com/gagliardetto/solana-go"
1413
"github.com/gagliardetto/solana-go/rpc"
1514
"github.com/gagliardetto/solana-go/rpc/jsonrpc"
@@ -264,13 +263,16 @@ func (w *WorkerSolana) retryGetTransaction(ctx context.Context, sig solana.Signa
264263
return nil // success
265264
}
266265

267-
eb := backoff.NewExponentialBackOff()
268-
eb.InitialInterval = 1 * time.Second
269-
eb.MaxElapsedTime = 8 * time.Second // limit retries
266+
tx, err := Retry(ctx, func(ctx context.Context) (*rpc.TransactionWithMeta, error) {
267+
err := operation()
268+
if err != nil {
269+
w.logger.Warnw("Retryable error", "err", err)
270+
}
270271

271-
err := backoff.Retry(operation, backoff.WithContext(eb, ctx))
272+
return tx, err
273+
})
272274
if err != nil {
273-
w.logger.Errorw("")
275+
w.logger.Errorw("Retry failed", "err", err)
274276
return nil, err
275277
}
276278

0 commit comments

Comments
 (0)