From 77e035efbd0f6cbadcca950cbee05a157a363bef Mon Sep 17 00:00:00 2001
From: helmutm <helmutm@fd906abe-77d9-0310-91a1-e0d9ade77398>
Date: Wed, 1 Aug 2007 16:25:28 +0000
Subject: [PATCH] provide Agent.scheduleJobsFromConfig() as part of the
 start-up procedure; work in progress: filesystem crawler

git-svn-id: svn://svn.cy55.de/Zope3/src/loops/trunk@1862 fd906abe-77d9-0310-91a1-e0d9ade77398
---
 agent/core.py     | 3 +++
 agent/schedule.py | 5 ++++-
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/agent/core.py b/agent/core.py
index 2e49e42..508a915 100644
--- a/agent/core.py
+++ b/agent/core.py
@@ -72,4 +72,7 @@ class Agent(object):
                     job.successors.append(transporter.jobFactory(transporter))
                 job.repeat = info.repeat or 0
                 self.scheduler.schedule(job, info.starttime or int(time()))
+                # TODO: remove job from config
+                # TODO: put repeating info in config
+                # TODO: remember last run for repeating job
 
diff --git a/agent/schedule.py b/agent/schedule.py
index 8a3653f..19aea08 100644
--- a/agent/schedule.py
+++ b/agent/schedule.py
@@ -72,11 +72,14 @@ class Job(object):
         # TODO: logging
 
     def finishRun(self, result):
+        # run successors
         for job in self.successors:
             job.params['result'] = result
             job.run(**job.params)
-        # TODO: remove from queue
+        # remove from queue
+        del self.scheduler.queue[self.startTime]
         # TODO: logging
+        # reschedule if necessary
         if self.repeat:
             self.reschedule(int(time() + self.repeat))