diff --git a/bridge/cmd/guardiand/main.go b/bridge/cmd/guardiand/main.go index cde92f7e3..3893d61be 100644 --- a/bridge/cmd/guardiand/main.go +++ b/bridge/cmd/guardiand/main.go @@ -180,10 +180,12 @@ func main() { // We need to re-fetch the initial initiator set when ethwatch dies, so we want to restart the watcher as well. // TODO: on-demand fetching of guardian set to avoid restarting ethwatch? - supervisor.RunGroup(ctx, map[string]supervisor.Runnable{ - "ethwatch": ethereum.NewEthBridgeWatcher(*ethRPC, ethContractAddr, *ethConfirmations, lockC, setC).Run, + if err := supervisor.RunGroup(ctx, map[string]supervisor.Runnable{ + "ethwatch": ethereum.NewEthBridgeWatcher(*ethRPC, ethContractAddr, *ethConfirmations, lockC, setC).Run, "ethlockup": ethLockupProcessor(lockC, setC, gk, sendC, ethObsvC, vaaC), - }) + }); err != nil { + return err + } if err := supervisor.Run(ctx, "solana", solana.NewSolanaBridgeWatcher(*agentRPC, lockC, vaaC).Run); err != nil {