From 10621625f0a720f846198998d57a023b8ad7f208 Mon Sep 17 00:00:00 2001 From: Leo Date: Fri, 21 Aug 2020 11:57:04 +0200 Subject: [PATCH] Handle supervisor.RunGroup error --- bridge/cmd/guardiand/main.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) 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 {