(self)
| 92 | return "DataBase Job %s:%s\n%sResult: %s" % (self.f.__name__, self.args[1:], output, self.result) |
| 93 | |
| 94 | def processJob(self): |
| 95 | try: |
| 96 | self.result = self.f(*self.args, **self.kwargs) |
| 97 | except Exception, e: |
| 98 | print_exc() |
| 99 | try: |
| 100 | print "Database Error @", self.f.__name__, self.args[1:], self.kwargs, e |
| 101 | except: |
| 102 | pass |
| 103 | |
| 104 | self.exception = e |
| 105 | finally: |
| 106 | self.done.set() |
| 107 | |
| 108 | def wait(self): |
| 109 | self.done.wait() |