diff --git a/orchestrator/cosmos/peggy/broadcast.go b/orchestrator/cosmos/peggy/broadcast.go index ab6d12fe..3bb7d865 100644 --- a/orchestrator/cosmos/peggy/broadcast.go +++ b/orchestrator/cosmos/peggy/broadcast.go @@ -111,11 +111,14 @@ func (c broadcastClient) SendValsetConfirm(_ context.Context, ethFrom gethcommon Signature: gethcommon.Bytes2Hex(signature), } - if err = c.ChainClient.QueueBroadcastMsg(msg); err != nil { + resp, err := c.ChainClient.SyncBroadcastMsg(msg) + if err != nil { metrics.ReportFuncError(c.svcTags) return errors.Wrap(err, "broadcasting MsgValsetConfirm failed") } + log.Debugln("SendValsetConfirm response", resp.String()) + return nil } diff --git a/orchestrator/signer.go b/orchestrator/signer.go index 979303f3..b0845a11 100644 --- a/orchestrator/signer.go +++ b/orchestrator/signer.go @@ -2,6 +2,7 @@ package orchestrator import ( "context" + "time" gethcommon "github.com/ethereum/go-ethereum/common" log "github.com/xlab/suplog" @@ -76,6 +77,8 @@ func (l *signer) signValidatorSets(ctx context.Context) error { } l.Log().WithFields(log.Fields{"valset_nonce": vs.Nonce, "validators": len(vs.Members)}).Infoln("confirmed valset update on Injective") + + time.Sleep(1200 * time.Millisecond) } return nil