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

scheduler: remove unnecessary reconnecting and ignore allocset assignment (#26298)

Browse Source 
These values aren't used anywhere, and the code is confusing as is.
This commit is contained in:
Piotr Kazmierczak
2025-07-21 09:06:52 +02:00
committed by GitHub
parent edd7b5b8e7
commit 973a554808
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
scheduler/reconciler/reconcile_cluster.go
View File

@@ -482,16 +482,14 @@ func (a *AllocReconciler) computeGroup(group string, all allocSet) (*ReconcileRe
reconnect, stopAllocSet, stopAllocResult := a.reconcileReconnecting(reconnecting, all, tg)
result.Stop = append(result.Stop, stopAllocResult...)
// Stop the reconciled allocations and remove them from the other sets
// since they have been already handled.
// Stop the reconciled allocations and remove them from untainted, migrate, lost
// and disconnecting sets, since they have been already handled.
result.DesiredTGUpdates[group].Stop += uint64(len(stopAllocSet))
untainted = untainted.difference(stopAllocSet)
migrate = migrate.difference(stopAllocSet)
lost = lost.difference(stopAllocSet)
disconnecting = disconnecting.difference(stopAllocSet)
reconnecting = reconnecting.difference(stopAllocSet)
ignore = ignore.difference(stopAllocSet)
// Validate and add reconnecting allocations to the plan so they are
// logged.