Skip to content

Commit fe064e0

Browse files
authored
Fix version discovery (#271)
1 parent e32307e commit fe064e0

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

service/local_slaves.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,9 @@ func (s *Service) startLocalSlaves(wg *sync.WaitGroup, config Config, bsCfg Boot
7777
wg.Add(1)
7878
go func() {
7979
defer wg.Done()
80-
slaveService.Run(s.stopPeer.ctx, slaveBsCfg, myPeers, relaunch)
80+
if err := slaveService.Run(s.stopPeer.ctx, slaveBsCfg, myPeers, relaunch); err != nil {
81+
s.log.Error().Str("peer", p.ID).Err(err).Msg("Unable to start one of peers")
82+
}
8183
}()
8284
}
8385
}

service/version_check.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ import (
2727
"context"
2828
"fmt"
2929
"strings"
30+
"time"
3031

3132
driver "github.com/arangodb/go-driver"
3233
"github.com/dchest/uniuri"
@@ -40,6 +41,8 @@ func (s *Service) DatabaseVersion(ctx context.Context) (driver.Version, error) {
4041
d, err := s.databaseVersion(ctx)
4142
if err != nil {
4243
s.log.Warn().Err(err).Msg("Error while getting version")
44+
time.Sleep(time.Second)
45+
continue
4346
}
4447

4548
return d, nil

0 commit comments

Comments
 (0)