equal
deleted
inserted
replaced
59 @dbdefer |
59 @dbdefer |
60 def setError(self, session, task, err): |
60 def setError(self, session, task, err): |
61 self.incStatus() |
61 self.incStatus() |
62 if self.status != "error": |
62 if self.status != "error": |
63 self._status(session,"error") |
63 self._status(session,"error") |
64 |
|
65 log.err(_why="Error: Job(%s) to '%s' failed."%(self.dbjob, task.recipient),_stuff=err) |
64 log.err(_why="Error: Job(%s) to '%s' failed."%(self.dbjob, task.recipient),_stuff=err) |
66 |
65 |
67 threadable.synchronize(ExJob) |
66 threadable.synchronize(ExJob) |
68 |
67 |
69 class ExJobs(dict, MutableMapping): |
68 class ExJobs(dict, MutableMapping): |