Skip to content

Commit

Permalink
Return resource control to ats to avoid scheduling issues
Browse files Browse the repository at this point in the history
  • Loading branch information
jwhite242 committed Mar 16, 2023
1 parent 2e1ccb3 commit 5698a1e
Showing 1 changed file with 5 additions and 14 deletions.
19 changes: 5 additions & 14 deletions ats/atsMachines/fluxScheduled.py
Original file line number Diff line number Diff line change
Expand Up @@ -126,8 +126,10 @@ def calculateCommandList(self, test):
FluxScheduled.set_nt_num_nodes(self, test)
# nn = test.options.get("nn", 0)

max_time = self.timelimit
ret.append(f"-t{max_time}")
# Remove to let ats control it and avoid needing excessively long allocation requests
# to prevent flux refusing to schedule jobs
# max_time = self.timelimit
# ret.append(f"-t{max_time}")

#if np > self.coresPerNode:
# nn = ceil(np / self.coresPerNode)
Expand Down Expand Up @@ -297,15 +299,4 @@ def remainingCapacity(self):
if self.numberNodesExclusivelyUsed >= self.numNodes:
return 0
else:
if (flux.resource.list.resource_list(self.fluxHandle).get().free.nnodes < 1):
return 0
else:
return flux.resource.list.resource_list(self.fluxHandle).get().free.ncores








return self.numProcsAvailable

0 comments on commit 5698a1e

Please sign in to comment.