[Checkins] SVN: Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/README.txt README test passes

Godefroid Chapelle gotcha at bubblenet.be
Mon Mar 8 11:32:31 EST 2010


Log message for revision 109837:
  README test passes

Changed:
  U   Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/README.txt

-=-
Modified: Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/README.txt
===================================================================
--- Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/README.txt	2010-03-08 16:32:17 UTC (rev 109836)
+++ Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/README.txt	2010-03-08 16:32:31 UTC (rev 109837)
@@ -17,31 +17,6 @@
   >>> from z3c import taskqueue
   >>> service = taskqueue.TaskService()
 
-The object should be located, so it gets a name:
-
-  >>> from zope.app.folder import Folder
-  >>> site1 = Folder()
-  >>> from zope.app.component.site import LocalSiteManager
-  >>> from zope.security.proxy import removeSecurityProxy
-  >>> sm = LocalSiteManager(removeSecurityProxy(site1))
-  >>> site1.setSiteManager(sm)
-
-  >>> sm['default']['testTaskService1'] = service
-  >>> service = sm['default']['testTaskService1'] # caution! proxy
-  >>> service.__name__
-  u'testTaskService1'
-  >>> service.__parent__ is sm['default']
-  True
-
-Let's register it under the name `TestTaskService1`:
-
-  >>> from zope import component
-  >>> from z3c.taskqueue import interfaces
-  >>> sm = site1.getSiteManager()
-  >>> sm.registerUtility(service, interfaces.ITaskService,
-  ...                          name='TestTaskService1')
-
-
 We can discover the available tasks:
 
   >>> service.getAvailableTasks()
@@ -104,6 +79,7 @@
 
   >>> jobid = service.add(u'echo', {'foo': 'bar'})
   >>> service.processNext()
+  True
 
   >>> service.getStatus(jobid)
   'completed'
@@ -122,6 +98,7 @@
 
   >>> jobid = service.add(u'error')
   >>> service.processNext()
+  True
 
 Let's now see what happened:
 
@@ -253,15 +230,18 @@
   >>> service.getStatus(jobid)
   'delayed'
   >>> service.processNext(0)
+  True
   >>> service.getStatus(jobid)
   'delayed'
   >>> service.processNext(9)
+  False
   >>> service.getStatus(jobid)
   'delayed'
 
 At 10 seconds the job is executed and completed.
 
   >>> service.processNext(10)
+  True
   >>> service.getStatus(jobid)
   'completed'
 
@@ -284,6 +264,7 @@
 early in time.
 
   >>> service.processNext(0)
+  False
   >>> service.getStatus(jobid)
   'cronjob'
   >>> service.getResult(jobid) is None
@@ -292,6 +273,7 @@
 Now we run the remote task 10 minutes later and get a result.
 
   >>> service.processNext(10*60)
+  True
   >>> service.getStatus(jobid)
   'cronjob'
   >>> service.getResult(jobid)
@@ -300,12 +282,14 @@
 And 1 minutes later it is not called.
 
   >>> service.processNext(11*60)
+  False
   >>> service.getResult(jobid)
   1
 
 But 3 minutes later it is called again.
 
   >>> service.processNext(13*60)
+  True
   >>> service.getResult(jobid)
   2
 
@@ -321,18 +305,21 @@
 Now the job is not executed at the old registration minute which was 10.
 
   >>> service.processNext(10*60+60*60)
+  False
   >>> service.getResult(jobid)
   2
 
 But it executes at the new minute which is set to 11.
 
   >>> service.processNext(11*60+60*60)
+  True
   >>> service.getResult(jobid)
   3
 
 Check Interfaces and stuff
 --------------------------
 
+  >>> from z3c.taskqueue import interfaces
   >>> from zope.interface.verify import verifyClass, verifyObject
   >>> verifyClass(interfaces.ITaskService, taskqueue.TaskService)
   True



More information about the checkins mailing list