[Checkins] SVN: Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/ remove leftover code related to processor
Godefroid Chapelle
gotcha at bubblenet.be
Mon Mar 8 05:56:57 EST 2010
Log message for revision 109820:
remove leftover code related to processor
Changed:
U Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/interfaces.py
U Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/tests.py
-=-
Modified: Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/interfaces.py
===================================================================
--- Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/interfaces.py 2010-03-08 10:55:05 UTC (rev 109819)
+++ Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/interfaces.py 2010-03-08 10:56:57 UTC (rev 109820)
@@ -274,30 +274,3 @@
required=False,
value_type=schema.TextLine(),
)
-
-
-class IProcessor(interface.Interface):
- """Job Processor
-
- Process the jobs that are waiting in the queue. A processor is meant to
- be run in a separate thread. To complete a job, it simply calls back into
- the task server. This works, since it does not use up any Web server
- threads.
-
- Processing a job can take a long time. However, we do not have to worry
- about transaction conflicts, since no other request is touching the job
- object.
- """
-
- running = schema.Bool(
- title=u"Running Flag",
- description=u"Tells whether the processor is currently running.",
- readonly=True)
-
- def __call__(db, servicePath):
- """Run the processor.
-
- The ``db`` is a ZODB instance that is used to call back into the task
- service. The ``servicePath`` specifies how to traverse to the task
- service itself.
- """
Modified: Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/tests.py
===================================================================
--- Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/tests.py 2010-03-08 10:55:05 UTC (rev 109819)
+++ Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/tests.py 2010-03-08 10:56:57 UTC (rev 109820)
@@ -32,8 +32,6 @@
log_info = InstalledHandler('lovely.remotetask')
test.globs['log_info'] = log_info
- test.origArgs = service.TaskService.processorArguments
- service.TaskService.processorArguments = {'waitTime': 0.0}
# Make tests predictable
random.seed(27)
@@ -44,7 +42,6 @@
log_info = test.globs['log_info']
log_info.clear()
log_info.uninstall()
- service.TaskService.processorArguments = test.origArgs
class TestIdGenerator(unittest.TestCase):
More information about the checkins
mailing list