From 15fdd2bac623e937b36223208cd3ef6bd73d0c73 Mon Sep 17 00:00:00 2001 From: Lucia Guevgeozian Odizzio Date: Tue, 17 Dec 2013 15:35:52 +0100 Subject: [PATCH] Bug fix in _needs_reschedule function --- src/nepi/execution/resource.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/nepi/execution/resource.py b/src/nepi/execution/resource.py index be803295..699af310 100644 --- a/src/nepi/execution/resource.py +++ b/src/nepi/execution/resource.py @@ -707,8 +707,10 @@ class ResourceManager(Logger): rm = self.ec.get_resource(guid) # If one of the RMs this resource needs to wait for has FAILED - # we raise an exception + # and is critical we raise an exception if rm.state == ResourceState.FAILED: + if not rm.get('critical'): + continue msg = "Resource can not wait for FAILED RM %d. Setting Resource to FAILED" raise RuntimeError, msg @@ -890,7 +892,7 @@ class ResourceManager(Logger): #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) -- 2.47.0