From 41ce36a96a85d8fe3dc7a8053de92edc18475fe4 Mon Sep 17 00:00:00 2001 From: Marcos Nicolau Date: Fri, 18 Oct 2024 16:45:32 -0300 Subject: [PATCH] test: tweak waiting times --- core/chainio/avs_writer.go | 2 +- core/utils/eth_client_utils.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/core/chainio/avs_writer.go b/core/chainio/avs_writer.go index 23ee054f4..037f4d9c2 100644 --- a/core/chainio/avs_writer.go +++ b/core/chainio/avs_writer.go @@ -119,7 +119,7 @@ func (w *AvsWriter) SendAggregatedResponse(batchIdentifierHash [32]byte, batchMe return nil, err } } - ctx, cancel := context.WithTimeout(context.Background(), time.Millisecond*200) + ctx, cancel := context.WithTimeout(context.Background(), time.Millisecond*2000) defer cancel() receipt, err := utils.WaitForTransactionReceipt(w.Client, ctx, tx.Hash()) diff --git a/core/utils/eth_client_utils.go b/core/utils/eth_client_utils.go index 792f34718..9d343ab01 100644 --- a/core/utils/eth_client_utils.go +++ b/core/utils/eth_client_utils.go @@ -13,7 +13,7 @@ import ( ) const maxRetries = 25 -const sleepTime = 5 * time.Second +const sleepTime = 1000 * time.Millisecond func WaitForTransactionReceipt(client eth.InstrumentedClient, ctx context.Context, txHash gethcommon.Hash) (*types.Receipt, error) { for i := 0; i < maxRetries; i++ { @@ -24,6 +24,7 @@ func WaitForTransactionReceipt(client eth.InstrumentedClient, ctx context.Contex } if err != nil { time.Sleep(sleepTime) + continue } else { return receipt, nil }