diff --git a/agent/base/agent.py b/agent/base/agent.py index 9acd09c..4bc1bb6 100644 --- a/agent/base/agent.py +++ b/agent/base/agent.py @@ -84,6 +84,9 @@ class Master(Agent): class SampleAgent(Agent): + def __init__(self, parent): + self.parent = parent + def execute(self, job, params=None): print 'Job %s on agent %s has been executed.' % (job.identifier, self.name) self.log(job) diff --git a/agent/base/schedule.py b/agent/base/schedule.py index b9acc98..12411e8 100644 --- a/agent/base/schedule.py +++ b/agent/base/schedule.py @@ -39,7 +39,7 @@ class Scheduler(object): self.queue = [] def schedule(self, job, startTime=None): - job. startTime = startTime or int(time()) + job.startTime = startTime or int(time()) self.queue.append(job) job.execute() # the sample scheduler does not care about startTime