equal
deleted
inserted
replaced
9 def __init__(self,queue): |
9 def __init__(self,queue): |
10 Process.__init__(self) |
10 Process.__init__(self) |
11 self.queue=queue |
11 self.queue=queue |
12 |
12 |
13 def run(self): |
13 def run(self): |
14 id=0 |
14 indifier=0 |
15 while 1: |
15 while 1: |
16 job=self.queue.get() |
16 job=self.queue.get() |
17 if job is None: |
17 if job is None: |
18 break # reached end of queue |
18 break # reached end of queue |
19 id+=1 |
19 indifier+=1 |
20 logger.info('ein neuer Job(%d)' %(id)) |
20 logger.info('ein neuer Job(%d)' %(indifier)) |
21 try: |
21 try: |
22 job.start(id) |
22 job.start(indifier) |
23 logger.info('Job(%d) fertig ;)'%(id)) |
23 logger.info('Job(%d) fertig ;)'%(indifier)) |
24 except: |
24 except: |
25 job.setStatus("error") |
25 job.setStatus("error") |
26 logger.exception('Job(%d) fehlgeschlagen :('%(id)) |
26 logger.exception('Job(%d) fehlgeschlagen :('%(indifier)) |
27 |
27 |