return self.ecstate in [ECState.FAILED, ECState.TERMINATED]
def wait_finished(self, guids):
- while not all([self.state(guid) == ResourceState.FINISHED \
+ while not all([self.state(guid) in [ResourceState.FINISHED,
+ ResourceState.STOPPED,
+ ResourceState.FAILED] \
for guid in guids]) and not self.finished:
# We keep the sleep as large as possible to
# decrese the number of RM state requests
import copy
import functools
-import inspect
+import logging
import os
import pkgutil
import weakref
types.append(attr)
except:
import traceback
+ import logging
err = traceback.format_exc()
logger = logging.getLogger("Resource.find_types()")
logger.error("Error while lading Resource Managers %s" % err)