diff --git a/orchestrator/cosmos/broadcast.go b/orchestrator/cosmos/broadcast.go index 469f9a54..b00766e3 100644 --- a/orchestrator/cosmos/broadcast.go +++ b/orchestrator/cosmos/broadcast.go @@ -3,6 +3,7 @@ package cosmos import ( "context" "fmt" + "time" sdk "github.com/cosmos/cosmos-sdk/types" ethcmn "github.com/ethereum/go-ethereum/common" @@ -354,6 +355,7 @@ func (s *peggyBroadcastClient) SendEthereumClaims( // Individual arrays (deposits, withdraws, valsetUpdates) are sorted. // Broadcast claim events sequentially starting with eventNonce = lastClaimEvent + 1. for count < totalClaimEvents { + time.Sleep(100 * time.Millisecond) if i < len(deposits) && deposits[i].EventNonce.Uint64() == lastClaimEvent+1 { // send deposit if err := s.sendDepositClaims(ctx, deposits[i]); err != nil { diff --git a/orchestrator/main_loops.go b/orchestrator/main_loops.go index c674be39..de9dce4b 100644 --- a/orchestrator/main_loops.go +++ b/orchestrator/main_loops.go @@ -21,7 +21,7 @@ import ( ethcmn "github.com/ethereum/go-ethereum/common" ) -const defaultLoopDur = 30 * time.Second +const defaultLoopDur = 60 * time.Second // Start combines the all major roles required to make // up the Orchestrator, all of these are async loops.