Skip to content
This repository has been archived by the owner on Nov 12, 2023. It is now read-only.

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
Fabio1988 committed Sep 26, 2023
1 parent e7463c1 commit b3ba259
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion worker/workerarea.go
Original file line number Diff line number Diff line change
Expand Up @@ -199,6 +199,7 @@ func (p *WorkerArea) RecalculateRouteParts() {
if now-ws.LastSeen <= workerUnseen {
activeWorkers = append(activeWorkers, ws)
} else {
log.Warnf("[WORKERAREA] Reset route parts of worker %s", ws.Uuid)
ws.ResetAreaAndRoutePart()
}
}
Expand All @@ -225,7 +226,7 @@ func (p *WorkerArea) RecalculateRouteParts() {
}

// Update worker states
ws := workersInArea[i]
ws := activeWorkers[i]
ws.StartStep = startStep
ws.EndStep = endStep
if ws.Step < ws.StartStep || ws.Step > ws.EndStep {
Expand Down

0 comments on commit b3ba259

Please sign in to comment.