Revision 14947dbc

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