[Checkins] SVN: Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/service.py pep8

[Godefroid Chapelle]

Log message for revision 109807:
  pep8

Changed:
  U   Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/service.py

-=-
Modified: Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/service.py
===================================================================
--- Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/service.py	2010-03-08 10:33:08 UTC (rev 109806)
+++ Sandbox/gotcha/z3c.taskqueue/src/z3c/taskqueue/service.py	2010-03-08 10:34:51 UTC (rev 109807)
@@ -20,7 +20,6 @@
 from zope import component
 from zope.app.appsetup.product import getProductConfiguration
 from zope.app.container import contained
-from zope.app.publication.zopepublication import ZopePublication
 from zope.component.interfaces import ComponentLookupError
 from zope.traversing.api import getParents
 import BTrees
@@ -51,7 +50,7 @@
     processorFactory = processor.SimpleProcessor
     processorArguments = {'waitTime': 1.0}
 
-    _scheduledJobs  = None
+    _scheduledJobs = None
     _scheduledQueue = None
     _v_nextid = None
     family = BTrees.family32
@@ -133,10 +132,9 @@
                 break
         if jobid in self.jobs:
             job = self.jobs[jobid]
-            if (   job.status == interfaces.CRONJOB
+            if (job.status == interfaces.CRONJOB
                 or job.status == interfaces.DELAYED
-                or job.status == interfaces.STARTLATER
-               ):
+                or job.status == interfaces.STARTLATER):
                 job.status = interfaces.CANCELLED
 
     def getStatus(self, jobid):
@@ -243,7 +241,7 @@
         try:
             jobtask = component.getUtility(self.taskInterface, name=job.task)
         except ComponentLookupError, error:
-            log.error('Task "%s" not found!'% job.task)
+            log.error('Task "%s" not found!' % job.task)
             log.exception(error)
             job.error = error
             if job.status != interfaces.CRONJOB:
@@ -303,9 +301,8 @@
                 self._scheduledJobs[first] = jobs[1:]
                 if len(self._scheduledJobs[first]) == 0:
                     del self._scheduledJobs[first]
-                if (    job.status != interfaces.CANCELLED
-                    and job.status != interfaces.ERROR
-                   ):
+                if (job.status != interfaces.CANCELLED
+                    and job.status != interfaces.ERROR):
                     if job.status != interfaces.DELAYED:
                         self._insertCronJob(job, now)
                     return job
@@ -349,7 +346,6 @@
             self._v_nextid = None
 
 
-
 def getAutostartServiceNames():
     """get a list of services to start"""