co-authored by
Aayush Rajasekaran
parent
33dfcf2663
commit
1e5e69ec9d
Vendored
+2
-2
@@ -81,7 +81,7 @@ func (ps *poStScheduler) Schedule(ctx context.Context, primary bool, spt abi.Reg
|
||||
defer ps.lk.Unlock()
|
||||
|
||||
if len(ps.workers) == 0 {
|
||||
return xerrors.Errorf("cant find %s post worker", ps.postType)
|
||||
return xerrors.Errorf("can't find %s post worker", ps.postType)
|
||||
}
|
||||
|
||||
// Get workers by resource
|
||||
@@ -120,7 +120,7 @@ type candidateWorker struct {
|
||||
|
||||
func (ps *poStScheduler) readyWorkers(spt abi.RegisteredSealProof) (bool, []candidateWorker) {
|
||||
var accepts []candidateWorker
|
||||
//if the gpus of the worker are insufficient or its disable, it cannot be scheduled
|
||||
//if the gpus of the worker are insufficient or it's disabled, it cannot be scheduled
|
||||
for wid, wr := range ps.workers {
|
||||
needRes := wr.info.Resources.ResourceSpec(spt, ps.postType)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user