cco/cybertools
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

make job params accessible to agent

Browse source 
git-svn-id: svn://svn.cy55.de/Zope3/src/cybertools/trunk@2511 fd906abe-77d9-0310-91a1-e0d9ade77398
This commit is contained in:
helmutm 2008-04-10 12:09:01 +00:00
parent 104d0ac88f
commit c998205e18
3 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
agent/base/agent.py
View file

@ -93,6 +93,7 @@ class Master(Agent):
job.agent = self.children[spec.agent] job.agent = self.children[spec.agent]
job.identifier = spec.identifier job.identifier = spec.identifier
job.controller = controller job.controller = controller
job.params = spec.params
self.scheduler.schedule(job, spec.startTime) self.scheduler.schedule(job, spec.startTime)
def notify(self, job, result=None, message=''): def notify(self, job, result=None, message=''):

1
agent/base/control.py
View file

@ -92,6 +92,7 @@ class JobSpecification(object):
def __init__(self, type, identifier, **kw): def __init__(self, type, identifier, **kw):
self.type = type self.type = type
self.identifier = identifier self.identifier = identifier
self.params = kw.pop('params', {})
for k, v in kw.items(): for k, v in kw.items():
setattr(self, k, v) setattr(self, k, v)

1
agent/core/agent.py
View file

@ -53,6 +53,7 @@ class QueueableAgent(Agent):
def execute(self, job): def execute(self, job):
job.state = states.running job.state = states.running
self.currentJob = job self.currentJob = job
self.params = job.params
d = self.process() d = self.process()
d.addCallbacks(self.completed, self.error) d.addCallbacks(self.completed, self.error)