mirror of
https://github.com/newnius/YAO-scheduler.git
synced 2025-06-07 22:31:55 +00:00
update
This commit is contained in:
parent
bc7092766c
commit
c6c7166475
@ -143,7 +143,7 @@ func (pool *ResourcePool) init(conf Configuration) {
|
|||||||
tasks = append(tasks, task)
|
tasks = append(tasks, task)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
log.Info(tasks)
|
//log.Info(tasks)
|
||||||
job := Job{Tasks: tasks}
|
job := Job{Tasks: tasks}
|
||||||
if len(tasks) == 0 {
|
if len(tasks) == 0 {
|
||||||
break
|
break
|
||||||
@ -916,7 +916,7 @@ func (pool *ResourcePool) doAcquireResource(job Job) []NodeStatus {
|
|||||||
|
|
||||||
//log.Info(tasks, factor)
|
//log.Info(tasks, factor)
|
||||||
allocation := InstanceOfAllocator().allocate(nodesT, tasks)
|
allocation := InstanceOfAllocator().allocate(nodesT, tasks)
|
||||||
//log.Info(allocation)
|
log.Info(allocation)
|
||||||
if allocation.Flags["valid"] {
|
if allocation.Flags["valid"] {
|
||||||
|
|
||||||
for range job.Tasks { //append would cause uncertain order
|
for range job.Tasks { //append would cause uncertain order
|
||||||
|
Loading…
Reference in New Issue
Block a user