equal
deleted
inserted
replaced
183 except Exception, exception: |
183 except Exception, exception: |
184 logging.exception(exception) |
184 logging.exception(exception) |
185 db.run_in_transaction(self.failJob, job_key) |
185 db.run_in_transaction(self.failJob, job_key) |
186 return self.ERRORED |
186 return self.ERRORED |
187 |
187 |
|
188 def iterate(self, jobs, retry_jobs): |
|
189 """Trivial iterator that iterates over jobs then retry_jobs |
|
190 """ |
|
191 |
|
192 for job in jobs: |
|
193 yield job |
|
194 while retry_jobs: |
|
195 yield retry_jobs[0] |
188 |
196 |
189 handler = Handler() |
197 handler = Handler() |