small bugfixes in members and tasks parsing
This commit is contained in:
parent
ac09ed749a
commit
3ef1dcecd7
4 changed files with 15 additions and 12 deletions
|
|
@ -36,24 +36,24 @@ class HostGroupMissingArgumentException(HostGroupException):
|
||||||
|
|
||||||
|
|
||||||
class HostGroup(object):
|
class HostGroup(object):
|
||||||
def __init__(self, name, **kwargs):
|
def __init__(self, _name, **kwargs):
|
||||||
self.name = name
|
self.name = _name
|
||||||
tmp = "members"
|
tmp = "members"
|
||||||
self.members = []
|
self.members = []
|
||||||
if not tmp in kwargs:
|
if not tmp in kwargs:
|
||||||
raise HostGroupMissingArgumentException(tmp, name)
|
raise HostGroupMissingArgumentException(tmp, _name)
|
||||||
self.add_members(kwargs[tmp])
|
self.add_members(kwargs[tmp])
|
||||||
|
|
||||||
tmp = "hosts"
|
tmp = "hosts"
|
||||||
self.hosts = []
|
self.hosts = []
|
||||||
if not tmp in kwargs:
|
if not tmp in kwargs:
|
||||||
raise HostGroupMissingArgumentException(tmp, name)
|
raise HostGroupMissingArgumentException(tmp, _name)
|
||||||
self.add_hosts(kwargs[tmp])
|
self.add_hosts(kwargs[tmp])
|
||||||
|
|
||||||
tmp = "services"
|
tmp = "services"
|
||||||
self.__services = []
|
self.__services = []
|
||||||
if not tmp in kwargs:
|
if not tmp in kwargs:
|
||||||
raise HostGroupMissingArgumentException(tmp, name)
|
raise HostGroupMissingArgumentException(tmp, _name)
|
||||||
self.add_services(kwargs[tmp])
|
self.add_services(kwargs[tmp])
|
||||||
|
|
||||||
self.parents = []
|
self.parents = []
|
||||||
|
|
|
||||||
|
|
@ -36,12 +36,12 @@ class MemberMissingArgumentException(MemberException):
|
||||||
|
|
||||||
|
|
||||||
class Member:
|
class Member:
|
||||||
def __init__(self, name="", **kwargs):
|
def __init__(self, _name, **kwargs):
|
||||||
self.name = name
|
self.name = _name
|
||||||
tmp = "tasks"
|
tmp = "tasks"
|
||||||
self.tasks = []
|
self.__tasks = []
|
||||||
if not tmp in kwargs:
|
if not tmp in kwargs:
|
||||||
raise MemberMissingArgumentException(tmp, name)
|
raise MemberMissingArgumentException(tmp, _name)
|
||||||
self.add_tasks(kwargs[tmp])
|
self.add_tasks(kwargs[tmp])
|
||||||
|
|
||||||
def __add_internal(self, l, item):
|
def __add_internal(self, l, item):
|
||||||
|
|
@ -50,6 +50,9 @@ class Member:
|
||||||
else:
|
else:
|
||||||
l.append(item)
|
l.append(item)
|
||||||
|
|
||||||
|
def get_name(self):
|
||||||
|
return self.name
|
||||||
|
|
||||||
def add_tasks(self, tasks):
|
def add_tasks(self, tasks):
|
||||||
self.__add_internal(self.get_tasks(), tasks)
|
self.__add_internal(self.get_tasks(), tasks)
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -114,9 +114,9 @@ class ConfigParser:
|
||||||
try:
|
try:
|
||||||
item = creator(key, val)
|
item = creator(key, val)
|
||||||
items.append(item)
|
items.append(item)
|
||||||
except Exception:
|
except Exception, e:
|
||||||
logger.warning("ignoring " + msgName + ": " + key + "! reason:")
|
logger.warning("ignoring " + msgName + ": " + key + "! reason:")
|
||||||
logger.warning(str(Exception))
|
logger.warning(str(e))
|
||||||
return items
|
return items
|
||||||
|
|
||||||
def _load_module(self, clazz, modPart):
|
def _load_module(self, clazz, modPart):
|
||||||
|
|
|
||||||
|
|
@ -28,7 +28,7 @@ KEY_ARGS = "args"
|
||||||
logger = getLogger(__name__)
|
logger = getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
class Task:
|
class Task(object):
|
||||||
def __init__(self, **kwargs):
|
def __init__(self, **kwargs):
|
||||||
|
|
||||||
self._args = {}
|
self._args = {}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue