From c998205e186097abd8d69fc1f316a36ab8a8644c Mon Sep 17 00:00:00 2001
From: helmutm <helmutm@fd906abe-77d9-0310-91a1-e0d9ade77398>
Date: Thu, 10 Apr 2008 12:09:01 +0000
Subject: [PATCH] make job params accessible to agent

git-svn-id: svn://svn.cy55.de/Zope3/src/cybertools/trunk@2511 fd906abe-77d9-0310-91a1-e0d9ade77398
---
 agent/base/agent.py   | 1 +
 agent/base/control.py | 1 +
 agent/core/agent.py   | 1 +
 3 files changed, 3 insertions(+)

diff --git a/agent/base/agent.py b/agent/base/agent.py
index 98a91b5..f7d94f8 100644
--- a/agent/base/agent.py
+++ b/agent/base/agent.py
@@ -93,6 +93,7 @@ class Master(Agent):
             job.agent = self.children[spec.agent]
             job.identifier = spec.identifier
             job.controller = controller
+            job.params = spec.params
             self.scheduler.schedule(job, spec.startTime)
 
     def notify(self, job, result=None, message=''):
diff --git a/agent/base/control.py b/agent/base/control.py
index a4204df..1670de8 100644
--- a/agent/base/control.py
+++ b/agent/base/control.py
@@ -92,6 +92,7 @@ class JobSpecification(object):
     def __init__(self, type, identifier, **kw):
         self.type = type
         self.identifier = identifier
+        self.params = kw.pop('params', {})
         for k, v in kw.items():
             setattr(self, k, v)
 
diff --git a/agent/core/agent.py b/agent/core/agent.py
index 63256b3..41a0fac 100644
--- a/agent/core/agent.py
+++ b/agent/core/agent.py
@@ -53,6 +53,7 @@ class QueueableAgent(Agent):
     def execute(self, job):
         job.state = states.running
         self.currentJob = job
+        self.params = job.params
         d = self.process()
         d.addCallbacks(self.completed, self.error)