Skip to content

Commit

Permalink
fix shard stuck on recovering status
Browse files Browse the repository at this point in the history
  • Loading branch information
hunjixin committed Apr 12, 2022
1 parent eac7733 commit f69894b
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions dagstore.go
Original file line number Diff line number Diff line change
Expand Up @@ -273,6 +273,8 @@ func (d *DAGStore) Start(ctx context.Context) error {
var toRegister, toRecover []*Shard
for _, s := range d.shards {
switch s.state {
case ShardStateRecovering:
fallthrough
case ShardStateErrored:
switch d.config.RecoverOnStart {
case DoNotRecover:
Expand All @@ -282,6 +284,7 @@ func (d *DAGStore) Start(ctx context.Context) error {
s.recoverOnNextAcquire = true
case RecoverNow:
log.Infow("start: recovering failed shard immediately", "shard", s.key, "error", s.err)
s.state = ShardStateErrored //force set state to error for recovering shard
toRecover = append(toRecover, s)
}

Expand Down

0 comments on commit f69894b

Please sign in to comment.