Skip to content
This repository was archived by the owner on Sep 12, 2024. It is now read-only.

Commit 432c7a2

Browse files
authored
Merge pull request #595 from CMSCompOps/equalizor_stepchain
use maximum number of cores of stepchain to check the memory
2 parents 44a0878 + aca2314 commit 432c7a2

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

Unified/equalizor.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -573,7 +573,7 @@ def overide_from_agent( wfi, needs_overide):
573573
wfi.sendLog('equalizor','The task %s was found to run short jobs of %.2f [mins] at original %d cores setting'%( taskname, set_time / mcore , mcore))
574574
short_tasks.add( (task.pathName, set_time / mcore, mcore) )
575575

576-
if mem and (mem > warning_mem*mcore):
576+
if mem and ((mem > warning_mem*mcore) if wfi.request['RequestType'] != 'StepChain' else (mem > warning_mem*wfi.getMulticore())):
577577
print "WHAT IS THIS TASK",task.pathName,"WITH",mem,"memory requirement at",mcore,"cores"
578578
wfi.sendLog('equalizor','The task %s was found to be confiugred with %d MB over %d MB/core at %d cores'%( taskname, mem, warning_mem, mcore))
579579
bad_hungry_tasks.add( (task.pathName, mem, mcore ) )

0 commit comments

Comments
 (0)