post worker sched: Filter out disabled workers correctly
This commit is contained in:
parent
6c0a2feade
commit
e170487faf
@ -196,7 +196,7 @@ func (m *Manager) generateWindowPoSt(ctx context.Context, minerID abi.ActorID, s
|
|||||||
skipped = append(skipped, sk...)
|
skipped = append(skipped, sk...)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
retErr = multierr.Append(retErr, xerrors.Errorf("partitionCount:%d err:%+v", partIdx, err))
|
retErr = multierr.Append(retErr, xerrors.Errorf("partitionIndex:%d err:%+v", partIdx, err))
|
||||||
}
|
}
|
||||||
flk.Unlock()
|
flk.Unlock()
|
||||||
}
|
}
|
||||||
|
@ -124,6 +124,11 @@ func (ps *poStScheduler) readyWorkers(spt abi.RegisteredSealProof) (bool, []cand
|
|||||||
for wid, wr := range ps.workers {
|
for wid, wr := range ps.workers {
|
||||||
needRes := wr.Info.Resources.ResourceSpec(spt, ps.postType)
|
needRes := wr.Info.Resources.ResourceSpec(spt, ps.postType)
|
||||||
|
|
||||||
|
if !wr.Enabled {
|
||||||
|
log.Debugf("sched: not scheduling on PoSt-worker %s, worker disabled", wid)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
if !wr.active.CanHandleRequest(ps.postType.SealTask(spt), needRes, wid, "post-readyWorkers", wr.Info) {
|
if !wr.active.CanHandleRequest(ps.postType.SealTask(spt), needRes, wid, "post-readyWorkers", wr.Info) {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user