aboutsummaryrefslogtreecommitdiff
path: root/ipsutils
diff options
context:
space:
mode:
authorJoseph Hunkeler <jhunkeler@gmail.com>2013-06-03 22:50:56 -0400
committerJoseph Hunkeler <jhunkeler@gmail.com>2013-06-03 22:50:56 -0400
commit401574c5843e6c479bf05367116b02300787124b (patch)
tree31dd4ef00bd99b5d324378ee348a09d853689205 /ipsutils
parent76377687dd84d8e9ef4cc5788bd5b594c1c966ed (diff)
downloadipsutils-401574c5843e6c479bf05367116b02300787124b.tar.gz
Remove NamedTask. Implemented Internal task class
Diffstat (limited to 'ipsutils')
-rw-r--r--ipsutils/task.py23
1 files changed, 11 insertions, 12 deletions
diff --git a/ipsutils/task.py b/ipsutils/task.py
index 94aed14..d64ce2d 100644
--- a/ipsutils/task.py
+++ b/ipsutils/task.py
@@ -16,6 +16,9 @@
class TaskException(Exception):
pass
+class InternalTaskException(Exception):
+ pass
+
class Controller(object):
def __init__(self):
self.stack = []
@@ -69,19 +72,15 @@ class Task(object):
def task(self):
raise NotImplementedError('Task undefined')
-
-
-class NamedTask(object):
- def __init__(self, name, func, *args):
- self.name = name
- self.task = func
- self.task_args = args
+
+class Internal(Task):
+ def __init__(self, *args, **kwargs):
+ super(Internal, self).__init__(self, *args, **kwargs)
def run(self):
- print("+ Running task: {0:s}".format(self.name))
- status = self.task(self.task_args)
+ if not self.name:
+ raise InternalTaskException("Unnamed task in : {}".format(self.name))
+ print("> Running internal task: {0:s}".format(self.name))
+ status = self.task()
return status
-
-class InternalTask(NamedTask):
- pass