kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-01 16:05:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

scheduler: check if system job deploy is complete before other guards (#26651)

Browse Source
This commit is contained in:
Piotr Kazmierczak
2025-08-28 17:29:13 +02:00
committed by GitHub
parent de342ee48b
commit 8b8e21dc0e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
scheduler/reconciler/reconcile_node.go
View File

@@ -428,7 +428,9 @@ func (nr *NodeReconciler) computeForNode(
result.Place = append(result.Place, allocTuple)
}
// check if deployment is place ready or complete
deploymentPlaceReady := !deploymentPaused && !deploymentFailed
deploymentComplete = nr.isDeploymentComplete(tg.Name, result)
// in this case there's nothing to do
if existingDeployment || tg.Update.IsEmpty() || (dstate.DesiredTotal == 0 && dstate.DesiredCanaries == 0) || !deploymentPlaceReady {
@@ -444,8 +446,6 @@ func (nr *NodeReconciler) computeForNode(
if maxParallel != 0 {
nr.createDeployment(job, tg, dstate, len(result.Update), liveAllocs)
}
deploymentComplete = nr.isDeploymentComplete(tg.Name, result)
}
return result, deploymentComplete