src/obitools/parallel/jobqueue.py

@@ -27,6 +27,7 @@ class JobPool(dict):
         self._toRun=set()
         self._runnerThread = threading.Thread(target=self._runner)
         self._runnerThread.start()
+        self._finalyzed=False
         
     def _runner(self):
         for rep in self._taskPool:
@@ -58,6 +59,8 @@ class JobPool(dict):
         @rtype: int
         '''
         
+        assert not self._finalyzed,\
+          "This jobPool does not accept new job"
         if job.submitted is not None:
             warning('Job %d was already submitted' % id(job))
             return id(job)
@@ -66,6 +69,7 @@ class JobPool(dict):
         job.priority  = priority
         job.userid    = userid
         i=id(job)
+        job.id=id
         self[i]=job
         self._toRun.add(job)
         
@@ -79,6 +83,7 @@ class JobPool(dict):
         be submitted. 
         '''
         self._iterator.finalyze()
+        self._finalyzed=True
         
     def __del__(self):
         self.finalyze()