[Checkins] SVN: Sandbox/gotcha/z3c.taskqueue/trunk/ service.processNext would not reset CronJob runCount

Godefroid Chapelle gotcha at bubblenet.be
Fri Nov 19 06:03:17 EST 2010


Log message for revision 118483:
  service.processNext would not reset CronJob runCount

Changed:
  U   Sandbox/gotcha/z3c.taskqueue/trunk/docs/HISTORY.txt
  U   Sandbox/gotcha/z3c.taskqueue/trunk/src/z3c/taskqueue/baseservice.py

-=-
Modified: Sandbox/gotcha/z3c.taskqueue/trunk/docs/HISTORY.txt
===================================================================
--- Sandbox/gotcha/z3c.taskqueue/trunk/docs/HISTORY.txt	2010-11-19 10:39:08 UTC (rev 118482)
+++ Sandbox/gotcha/z3c.taskqueue/trunk/docs/HISTORY.txt	2010-11-19 11:03:16 UTC (rev 118483)
@@ -4,7 +4,7 @@
 0.1-alpha-3 (unreleased)
 ------------------------
 
-- Nothing changed yet.
+- Fix : service.processNext would not reset CronJob runCount
 
 
 0.1-alpha-2 (2010-10-19)

Modified: Sandbox/gotcha/z3c.taskqueue/trunk/src/z3c/taskqueue/baseservice.py
===================================================================
--- Sandbox/gotcha/z3c.taskqueue/trunk/src/z3c/taskqueue/baseservice.py	2010-11-19 10:39:08 UTC (rev 118482)
+++ Sandbox/gotcha/z3c.taskqueue/trunk/src/z3c/taskqueue/baseservice.py	2010-11-19 11:03:16 UTC (rev 118483)
@@ -221,6 +221,8 @@
                 job.error = error
                 if job.status != interfaces.CRONJOB:
                     job.status = interfaces.ERROR
+                else:
+                    storage.runCount = 0
         job.completed = datetime.datetime.now()
         return True
 
@@ -311,7 +313,8 @@
         #
         db = z3c.taskqueue.GLOBALDB
         if db is None:
-            raise ValueError('z3c.taskqueue.GLOBALDB is not initialized; should be done with IDatabaseOpenedWithRootEvent')
+            raise ValueError('z3c.taskqueue.GLOBALDB is not initialized; '
+                'should be done with IDatabaseOpenedWithRootEvent')
         processor = self.processorFactory(
             db, servicePath, **self.processorArguments)
         threadName = self._threadName()



More information about the checkins mailing list