git://git.onelab.eu
/
nepi.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Adding Linux Application scalability tests
[nepi.git]
/
src
/
neco
/
execution
/
resource.py
diff --git
a/src/neco/execution/resource.py
b/src/neco/execution/resource.py
index
0eb0d64
..
762e80e
100644
(file)
--- a/
src/neco/execution/resource.py
+++ b/
src/neco/execution/resource.py
@@
-464,12
+464,20
@@
class ResourceManager(object):
reschedule = True
self.debug("---- RESCHEDULING START ---- state %s " % self.state )
else:
reschedule = True
self.debug("---- RESCHEDULING START ---- state %s " % self.state )
else:
- self.debug("---- START CONDITIONS ---- %s" %
- self.conditions.get(ResourceAction.START))
+ start_conditions = self.conditions.get(ResourceAction.START, [])
+
+ self.debug("---- START CONDITIONS ---- %s" % start_conditions)
# Verify all start conditions are met
# Verify all start conditions are met
- start_conditions = self.conditions.get(ResourceAction.START, [])
for (group, state, time) in start_conditions:
for (group, state, time) in start_conditions:
+ # Uncomment for debug
+ #unmet = []
+ #for guid in group:
+ # rm = self.ec.get_resource(guid)
+ # unmet.append((guid, rm._state))
+ #
+ #self.debug("---- WAITED STATES ---- %s" % unmet )
+
reschedule, delay = self._needs_reschedule(group, state, time)
if reschedule:
break
reschedule, delay = self._needs_reschedule(group, state, time)
if reschedule:
break