X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fneco%2Fexecution%2Fresource.py;h=762e80e8290e9ceb6dbca5e0a0a99409c74afd1a;hb=94f4bad47f6b00e8d1e9ad9c55bfbbd6894329fc;hp=0eb0d64703ed4b07264fa968fe8a6941b264eb55;hpb=d32dba78910bd348b9bbeb0e8242d31bfd39c0a7;p=nepi.git

diff --git a/src/neco/execution/resource.py b/src/neco/execution/resource.py
index 0eb0d647..762e80e8 100644
--- 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:
-            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
-            start_conditions = self.conditions.get(ResourceAction.START, [])
             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