Revision 14947dbc tools/burnin
| b/tools/burnin | ||
|---|---|---|
| 385 | 385 |
|
| 386 | 386 |
""" |
| 387 | 387 |
self.ClearFeedbackBuf() |
| 388 |
job_ids = [cli.SendJob(row[0], cl=self.cl) for row in jobs] |
|
| 389 |
Log("Submitted job ID(s) %s", utils.CommaJoin(job_ids), indent=1)
|
|
| 390 |
results = [] |
|
| 391 |
for jid, (_, iname) in zip(job_ids, jobs): |
|
| 392 |
Log("waiting for job %s for %s", jid, iname, indent=2)
|
|
| 393 |
try: |
|
| 394 |
results.append(cli.PollJob(jid, cl=self.cl, feedback_fn=self.Feedback)) |
|
| 395 |
except Exception, err: # pylint: disable-msg=W0703 |
|
| 396 |
Log("Job for %s failed: %s", iname, err)
|
|
| 397 |
if len(results) != len(jobs): |
|
| 388 |
jex = cli.JobExecutor(cl=self.cl, feedback_fn=self.Feedback) |
|
| 389 |
for ops, name in jobs: |
|
| 390 |
jex.QueueJob(name, *ops) # pylint: disable-msg=W0142 |
|
| 391 |
try: |
|
| 392 |
results = jex.GetResults() |
|
| 393 |
except Exception, err: # pylint: disable-msg=W0703 |
|
| 394 |
Log("Jobs failed: %s", err)
|
|
| 398 | 395 |
raise BurninFailure() |
| 399 |
return results |
|
| 396 |
|
|
| 397 |
if utils.any(results, lambda x: not x[0]): |
|
| 398 |
raise BurninFailure() |
|
| 399 |
|
|
| 400 |
return [i[1] for i in results] |
|
| 400 | 401 |
|
| 401 | 402 |
def ParseOptions(self): |
| 402 | 403 |
"""Parses the command line options. |
Also available in: Unified diff