Changeset 9102 for main/waeup.kofa/branches/uli-zc-async/src/waeup/kofa/async.py

Timestamp:

9 Aug 2012, 09:52:28 (12 years ago)

Author:

uli

Message:

Support duration setting for async test jobs.

File:

• main/waeup.kofa/branches/uli-zc-async/src/waeup/kofa/async.py (modified) (5 diffs)

main/waeup.kofa/branches/uli-zc-async/src/waeup/kofa/async.py

@@ -35 +35 @@
     )
 
-def compute(num):
+def compute(num, duration=60):
     """A convenience function to test asynchronous jobs.
+
+    `duration` gives the seconds, this job should (artificially) need
+    for completing.
     """
     start = time.time()
-    duration = 60
     end = start + duration
     print "MyJob starts computation at ", start
@@ -60 +62 @@
         print "MyJob's percent: %r" % zc.async.local.getLiveAnnotation(
             'percent')
+    zc.async.local.setLiveAnnotation('percent', 100.0)
     return num * 2
 
@@ -70 +73 @@
     grok.implements(IJob, IProgressable)
     grok.provides(IJob)
-
     percent = None
 
@@ -183 +185 @@
         return
 
-    def start_test_job(self):
+    def start_test_job(self, duration=60, site=None):
         """Start a test job.
 
@@ -190 +192 @@
         :func:`compute` function with ``23`` as argument.
         """
-        job = AsyncJob(compute, 23)
-        job_id = self.put(job)
+        job = AsyncJob(compute, 23, duration)
+        job_id = self.put(job, site=site)
         return job_id