--- a/iro/joblist.py Fri Oct 08 02:59:04 2010 +0200
+++ b/iro/joblist.py Wed Nov 03 01:18:38 2010 +0100
@@ -13,17 +13,19 @@
from anbieter import content
import md5, os, time
-
+import logging
+logger=logging.getLogger("iro.joblist");
class Joblist:
'''
Providing an list of jobs; each new job gets a hash id
'''
- def __init__(self,manager, queue,providerlist):
+ def __init__(self,manager, queue,providerlist,dbconn=None):
self.jobs={}
self.manager=manager
self.queue=queue
self.providerlist=providerlist
+ self.dbconn=dbconn
def __getitem__(self,key):
@@ -31,6 +33,9 @@
def __registerJob__(self, job):
id = self._createID()
+ if self.dbconn:
+ job.setAcounting(self.manager.Acounting(id,self.dbconn))
+ job.setId(id)
self.jobs[id]=job
self.queue.put(job)
return id