X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fnepi%2Fexecution%2Fresource.py;h=5ec0be383d8ed8b57ec3daa7510aa842d3a0984e;hb=f7c6792813947d3707accd690ad7bbe83277798f;hp=e82ced043a006ebc4ba0b32a7de5e42388a4573f;hpb=7b73c5d0b8d2c03116baef752357a52998f451f0;p=nepi.git diff --git a/src/nepi/execution/resource.py b/src/nepi/execution/resource.py index e82ced04..5ec0be38 100644 --- a/src/nepi/execution/resource.py +++ b/src/nepi/execution/resource.py @@ -749,6 +749,18 @@ class ResourceManager(Logger): connected.append(rm) return connected + def is_rm_instance(self, rtype): + """ Returns True if the RM is instance of 'rtype' + + :param rtype: Type of the RM we look for + :type rtype: str + :return: True|False + """ + rclass = ResourceFactory.get_resource_type(rtype) + if isinstance(self, rclass): + return True + return False + @failtrap def _needs_reschedule(self, group, state, time): """ Internal method that verify if 'time' has elapsed since